google-cloud-bigquery overview (2.22.0)

com.google.cloud.bigquery

A client for BigQuery – 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");
 }

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);