com.google.cloud.bigquery
A client for BigQuery \u2013 A fully managed, petabyte scale, low cost enterprise data warehouse for analytics.
A simple usage example showing how to create a table if it does not exist and load data into it. For the complete source code see CreateTableAndLoadData.java.
BigQuery bigquery = BigQueryOptions.getDefaultInstance().getService();
TableId tableId = TableId.of("dataset", "table");
Table table = bigquery.getTable(tableId);
if (table == null) {
System.out.println("Creating table " + tableId);
Field integerField = Field.of("fieldName", Field.Type.integer());
Schema schema = Schema.of(integerField);
table = bigquery.create(TableInfo.of(tableId, StandardTableDefinition.of(schema)));
}
System.out.println("Loading data into table " + tableId);
Job loadJob = table.load(FormatOptions.csv(), "gs://bucket/path");
loadJob = loadJob.waitFor();
if (loadJob.getStatus().getError() != null) {
System.out.println("Job completed with errors");
} else {
System.out.println("Job succeeded");
}
See Also: Google Cloud BigQuery
com.google.cloud.bigquery.benchmark
com.google.cloud.bigquery.spi
com.google.cloud.bigquery.spi.v2
com.google.cloud.bigquery.testing
A testing helper for Google BigQuery.
A simple usage example:
Before the test:
RemoteBigQueryHelper bigqueryHelper = RemoteBigQueryHelper.create();
BigQuery bigquery = bigqueryHelper.getOptions().getService();
String dataset = RemoteBigQueryHelper.generateDatasetName();
bigquery.create(DatasetInfo.newBuilder(dataset).build());
After the test:
RemoteBigQueryHelper.forceDelete(bigquery, DATASET);
See Also: Google Cloud Java tools for testing