import com.google.cloud.bigquery.BigQuery;
import com.google.cloud.bigquery.BigQueryException;
import com.google.cloud.bigquery.BigQueryOptions;
import com.google.cloud.bigquery.QueryJobConfiguration;
import com.google.cloud.bigquery.TableResult;
public class QueryMaterializedView {
public static void main(String[] args) throws InterruptedException {
// TODO(developer): Replace these variables before running the sample.
String datasetName = "MY_DATASET_NAME";
String materializedViewName = "MY_MATERIALIZED_VIEW_NAME";
String query = String.format("SELECT * FROM %s.%s", datasetName, materializedViewName);
queryMaterializedView(query);
}
public static void queryMaterializedView(String query) throws InterruptedException {
try {
// Initialize client that will be used to send requests. This client only needs to be created
// once, and can be reused for multiple requests.
BigQuery bigquery = BigQueryOptions.getDefaultInstance().getService();
TableResult results = bigquery.query(QueryJobConfiguration.of(query));
results
.iterateAll()
.forEach(row -> row.forEach(val -> System.out.printf("%s\n", val.toString())));
System.out.println("Query performed successfully.");
} catch (BigQueryException e) {
System.out.println("Query was not performed. \n" + e.toString());
}
}
}
