Example of ensuring that a table exists. + *
{@code
+ * if (!table.exists()) {
+ * throw new RuntimeException("Table does not exist.");
+ * }
+ * }
+ *
* @return {@code true} if this table exists, {@code false} otherwise
* @throws BigQueryException upon failure
*/
@@ -149,6 +156,13 @@ public boolean exists() {
/**
* Fetches current table's latest information. Returns {@code null} if the table does not exist.
*
+ * Example of fetching a table's latest information, specifying particular table field options. + *
{@code
+ * TableField field1 = TableField.LAST_MODIFIED_TIME;
+ * TableField field2 = TableField.NUM_ROWS;
+ * Table reloaded = table.reload(TableOption.fields(field1, field2));
+ * }
+ *
* @param options table options
* @return a {@code Table} object with latest information or {@code null} if not found
* @throws BigQueryException upon failure
@@ -161,6 +175,13 @@ public Table reload(TableOption... options) {
* Updates the table's information with this table's information. Dataset's and table's
* user-defined ids cannot be changed. A new {@code Table} object is returned.
*
+ * Example of updating a table's information, specifying particular table field options. + *
{@code
+ * TableField field1 = TableField.LAST_MODIFIED_TIME;
+ * TableField field2 = TableField.NUM_ROWS;
+ * Table updated = table.update(TableOption.fields(field1, field2));
+ * }
+ *
* @param options dataset options
* @return a {@code Table} object with updated information
* @throws BigQueryException upon failure
@@ -172,6 +193,11 @@ public Table update(TableOption... options) {
/**
* Deletes this table.
*
+ * Example of deleting a table. + *
{@code
+ * table.delete();
+ * }
+ *
* @return {@code true} if table was deleted, {@code false} if it was not found
* @throws BigQueryException upon failure
*/
@@ -182,6 +208,23 @@ public boolean delete() {
/**
* Insert rows into the table.
*
+ * Example of inserting rows into a table. + *
{@code
+ * String rowId1 = "rowId1";
+ * String rowId2 = "rowId2";
+ * List rows = new ArrayList<>();
+ * Map row1 = new HashMap<>();
+ * row1.put("stringField", "value1");
+ * row1.put("booleanField", true);
+ * Map row2 = new HashMap<>();
+ * row2.put("stringField", "value2");
+ * row2.put("booleanField", false);
+ * rows.add(RowToInsert.of(rowId1, row1));
+ * rows.add(RowToInsert.of(rowId2, row2));
+ * InsertAllResponse response = table.insert(rows);
+ * // do something with response
+ * }
+ *
* @param rows rows to be inserted
* @throws BigQueryException upon failure
*/
@@ -193,6 +236,23 @@ public InsertAllResponse insert(IterableExample of inserting rows into a table which ignores invalid rows. + *
{@code
+ * String rowId1 = "rowId1";
+ * String rowId2 = "rowId2";
+ * List rows = new ArrayList<>();
+ * Map row1 = new HashMap<>();
+ * row1.put("stringField", 1);
+ * row1.put("booleanField", true);
+ * Map row2 = new HashMap<>();
+ * row2.put("stringField", "value2");
+ * row2.put("booleanField", false);
+ * rows.add(RowToInsert.of(rowId1, row1));
+ * rows.add(RowToInsert.of(rowId2, row2));
+ * InsertAllResponse response = table.insert(rows, true, true);
+ * // do something with response
+ * }
+ *
* @param rows rows to be inserted
* @param skipInvalidRows whether to insert all valid rows, even if invalid rows exist. If not set
* the entire insert operation will fail if rows to be inserted contain an invalid row
@@ -213,6 +273,12 @@ public InsertAllResponse insert(IterableExample of getting a paginated list of rows in a table. + *
{@code
+ * Page> page = table.list(TableDataListOption.pageSize(100));
+ * // do something with page
+ * }
+ *
* @param options table data list options
* @throws BigQueryException upon failure
*/
@@ -225,6 +291,27 @@ public PageExample of copying a table to a destination table and dataset referenced by name. + *
{@code
+ * String datasetName = "my_dataset";
+ * String tableName = "my_destination_table";
+ * Job job = table.copy(datasetName, tableName);
+ *
+ * // Wait for the job to complete.
+ * try {
+ * Job completedJob = job.waitFor(WaitForOption.checkEvery(1, TimeUnit.SECONDS),
+ * WaitForOption.timeout(60, TimeUnit.SECONDS));
+ * if (completedJob != null && completedJob.status().error() == null) {
+ * // Job completed successfully.
+ * } else {
+ * // Handle error case.
+ * }
+ * } catch (InterruptedException | TimeoutException e) {
+ * // Handle interrupted wait.
+ * }
+ *
+ * }
+ *
* @param destinationDataset the user-defined id of the destination dataset
* @param destinationTable the user-defined id of the destination table
* @param options job options
@@ -239,6 +326,29 @@ public Job copy(String destinationDataset, String destinationTable, JobOption...
* Starts a BigQuery Job to copy the current table to the provided destination table. Returns the
* started {@link Job} object.
*
+ * Example copying a table to a destination table referenced by table ID. + *
{@code
+ * String dataset = "my_dataset";
+ * String tableName = "copy_destination";
+ * TableId destinationId = TableId.of(dataset, tableName);
+ * JobOption options = JobOption.fields(JobField.STATUS, JobField.USER_EMAIL);
+ *
+ * Job job = table.copy(destinationId, options);
+ *
+ * // Wait for the job to complete.
+ * try {
+ * Job completedJob = job.waitFor(WaitForOption.checkEvery(1, TimeUnit.SECONDS),
+ * WaitForOption.timeout(60, TimeUnit.SECONDS));
+ * if (completedJob != null && completedJob.status().error() == null) {
+ * // Job completed successfully.
+ * } else {
+ * // Handle error case.
+ * }
+ * } catch (InterruptedException | TimeoutException e) {
+ * // Handle interrupted wait.
+ * }
+ * }
+ *
* @param destinationTable the destination table of the copy job
* @param options job options
* @throws BigQueryException upon failure
@@ -253,6 +363,26 @@ public Job copy(TableId destinationTable, JobOption... options)
* Starts a BigQuery Job to extract the current table to the provided destination URI. Returns the
* started {@link Job} object.
*
+ * Example extracting data to single Google Cloud Storage file. + *
{@code
+ * String format = "CSV";
+ * String gcsUrl = "gs://myapp.appspot.com/filename.csv";
+ * Job job = table.extract(format, gcsUrl);
+ *
+ * // Wait for the job to complete.
+ * try {
+ * Job completedJob = job.waitFor(WaitForOption.checkEvery(1, TimeUnit.SECONDS),
+ * WaitForOption.timeout(60, TimeUnit.SECONDS));
+ * if (completedJob != null && completedJob.status().error() == null) {
+ * // Job completed successfully.
+ * } else {
+ * // Handle error case.
+ * }
+ * } catch (InterruptedException | TimeoutException e) {
+ * // Handle interrupted wait.
+ * }
+ * }
+ *
* @param format the format of the extracted data
* @param destinationUri the fully-qualified Google Cloud Storage URI (e.g. gs://bucket/path)
* where the extracted table should be written
@@ -268,6 +398,31 @@ public Job extract(String format, String destinationUri, JobOption... options)
* Starts a BigQuery Job to extract the current table to the provided destination URIs. Returns
* the started {@link Job} object.
*
+ * Example extracting data to a list of Google Cloud Storage files. + *
{@code
+ * String format = "CSV";
+ * String gcsUrl1 = "gs://myapp.appspot.com/PartitionA_*.csv";
+ * String gcsUrl2 = "gs://myapp.appspot.com/PartitionB_*.csv";
+ * List destinationUris = new ArrayList<>();
+ * destinationUris.add(gcsUrl1);
+ * destinationUris.add(gcsUrl2);
+ *
+ * Job job = table.extract(format, destinationUris);
+ *
+ * // Wait for the job to complete.
+ * try {
+ * Job completedJob = job.waitFor(WaitForOption.checkEvery(1, TimeUnit.SECONDS),
+ * WaitForOption.timeout(60, TimeUnit.SECONDS));
+ * if (completedJob != null && completedJob.status().error() == null) {
+ * // Job completed successfully.
+ * } else {
+ * // Handle error case.
+ * }
+ * } catch (InterruptedException | TimeoutException e) {
+ * // Handle interrupted wait.
+ * }
+ * }
+ *
* @param format the format of the exported data
* @param destinationUris the fully-qualified Google Cloud Storage URIs (e.g. gs://bucket/path)
* where the extracted table should be written
@@ -285,6 +440,25 @@ public Job extract(String format, ListExample loading data from a single Google Cloud Storage file. + *
{@code
+ * String sourceUri = "gs://myapp.appspot.com/filename.csv";
+ * Job job = table.load(FormatOptions.csv(), sourceUri);
+ *
+ * // Wait for the job to complete.
+ * try {
+ * Job completedJob = job.waitFor(WaitForOption.checkEvery(1, TimeUnit.SECONDS),
+ * WaitForOption.timeout(60, TimeUnit.SECONDS));
+ * if (completedJob != null && completedJob.status().error() == null) {
+ * // Job completed successfully.
+ * } else {
+ * // Handle error case.
+ * }
+ * } catch (InterruptedException | TimeoutException e) {
+ * // Handle interrupted wait.
+ * }
+ * }
+ *
* @param format the format of the data to load
* @param sourceUri the fully-qualified Google Cloud Storage URI (e.g. gs://bucket/path) from
* which to load the data
@@ -300,6 +474,30 @@ public Job load(FormatOptions format, String sourceUri, JobOption... options)
* Starts a BigQuery Job to load data into the current table from the provided source URIs.
* Returns the started {@link Job} object.
*
+ * Example loading data from a list of Google Cloud Storage files. + *
{@code
+ * String gcsUrl1 = "gs://myapp.appspot.com/PartitionA_000000000000.csv";
+ * String gcsUrl2 = "gs://myapp.appspot.com/PartitionB_000000000000.csv";
+ * List sourceUris = new ArrayList<>();
+ * sourceUris.add(gcsUrl1);
+ * sourceUris.add(gcsUrl2);
+ *
+ * Job job = table.load(FormatOptions.csv(), sourceUris);
+ *
+ * // Wait for the job to complete.
+ * try {
+ * Job completedJob = job.waitFor(WaitForOption.checkEvery(1, TimeUnit.SECONDS),
+ * WaitForOption.timeout(60, TimeUnit.SECONDS));
+ * if (completedJob != null && completedJob.status().error() == null) {
+ * // Job completed successfully.
+ * } else {
+ * // Handle error case.
+ * }
+ * } catch (InterruptedException | TimeoutException e) {
+ * // Handle interrupted wait.
+ * }
+ * }
+ *
* @param format the format of the exported data
* @param sourceUris the fully-qualified Google Cloud Storage URIs (e.g. gs://bucket/path) from
* which to load the data
diff --git a/google-cloud-examples/src/main/java/com/google/cloud/examples/bigquery/snippets/TableSnippets.java b/google-cloud-examples/src/main/java/com/google/cloud/examples/bigquery/snippets/TableSnippets.java
new file mode 100644
index 000000000000..8f9e0d46bc91
--- /dev/null
+++ b/google-cloud-examples/src/main/java/com/google/cloud/examples/bigquery/snippets/TableSnippets.java
@@ -0,0 +1,327 @@
+/*
+ * Copyright 2016 Google Inc. All Rights Reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.google.cloud.examples.bigquery.snippets;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.TimeoutException;
+
+import com.google.cloud.Page;
+import com.google.cloud.WaitForOption;
+import com.google.cloud.bigquery.BigQuery.JobField;
+import com.google.cloud.bigquery.BigQuery.JobOption;
+import com.google.cloud.bigquery.BigQuery.TableDataListOption;
+import com.google.cloud.bigquery.BigQuery.TableField;
+import com.google.cloud.bigquery.BigQuery.TableOption;
+import com.google.cloud.bigquery.BigQueryException;
+import com.google.cloud.bigquery.FieldValue;
+import com.google.cloud.bigquery.FormatOptions;
+import com.google.cloud.bigquery.InsertAllRequest.RowToInsert;
+import com.google.cloud.bigquery.InsertAllResponse;
+import com.google.cloud.bigquery.Job;
+import com.google.cloud.bigquery.Table;
+import com.google.cloud.bigquery.TableId;
+
+/*
+ * EDITING INSTRUCTIONS
+ * This file is referenced in Table’s javadoc. Any change to this file should be reflected in
+ * Table’s javadoc.
+ */
+public class TableSnippets {
+ private final Table table;
+
+ public TableSnippets(Table table) {
+ this.table = table;
+ }
+
+ /**
+ * Example of ensuring that a table exists.
+ */
+ // [TARGET exists()]
+ public void checkExists() {
+ // [START checkExists]
+ if (!table.exists()) {
+ throw new IllegalArgumentException("Table does not exist.");
+ }
+ // [END checkExists]
+ }
+
+ /**
+ * Example of fetching a table's latest information, specifying particular table field options.
+ */
+ // [TARGET reload(TableOption...)]
+ // [VARIABLE TableField.LAST_MODIFIED_TIME]
+ // [VARIABLE TableField.NUM_ROWS]
+ public Table reloadTableWithFields(TableField field1, TableField field2) {
+ // [START reloadTableWithFields]
+ Table reloaded = table.reload(TableOption.fields(field1, field2));
+ // [END reloadTableWithFields]
+ return reloaded;
+ }
+
+ /**
+ * Example of updating a table's information, specifying particular table field options.
+ */
+ // [TARGET update(TableOption...)]
+ // [VARIABLE TableField.LAST_MODIFIED_TIME]
+ // [VARIABLE TableField.NUM_ROWS]
+ public Table updateTableWithFields(TableField field1, TableField field2) {
+ // [START updateTableWithFields]
+ Table updated = table.update(TableOption.fields(field1, field2));
+ // [END updateTableWithFields]
+ return updated;
+ }
+
+ /**
+ * Example of deleting a table.
+ */
+ // [TARGET delete()]
+ public void delete() {
+ // [START delete]
+ table.delete();
+ // [END delete]
+ }
+
+ /**
+ * Example of inserting rows into a table.
+ */
+ // [TARGET insert(Iterable)]
+ // [VARIABLE "rowId1"]
+ // [VARIABLE "rowId2"]
+ public InsertAllResponse insert(String rowId1, String rowId2) {
+ // [START insert]
+ List