com.google.cloud.bigquery

Class InsertAllRequest.Builder

java.lang.Object

com.google.cloud.bigquery.InsertAllRequest.Builder

Enclosing class:

InsertAllRequest

public static final class InsertAllRequest.Builder
extends Object

Method Summary

Methods

Modifier and Type	Method and Description
InsertAllRequest.Builder	addRow(InsertAllRequest.RowToInsert rowToInsert) Adds a row to be inserted.
InsertAllRequest.Builder	addRow(Map<String,Object> content) Adds a row to be inserted without an associated id.
InsertAllRequest.Builder	addRow(String id, Map<String,Object> content) Adds a row to be inserted with associated id.
InsertAllRequest	build()
InsertAllRequest.Builder	ignoreUnknownValues(boolean ignoreUnknownValues) Sets whether to accept rows that contain values that do not match the schema.
InsertAllRequest.Builder	rows(Iterable<InsertAllRequest.RowToInsert> rows) Sets the rows to insert as a list of InsertAllRequest.RowToInsert objects.
InsertAllRequest.Builder	skipInvalidRows(boolean skipInvalidRows) Sets whether to insert all valid rows of a request, even if invalid rows exist.
InsertAllRequest.Builder	table(TableId table) Sets the destination table for rows insert request.
InsertAllRequest.Builder	templateSuffix(String templateSuffix) If specified, the destination table is treated as a base template.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

table

public InsertAllRequest.Builder table(TableId table)

Sets the destination table for rows insert request.

rows

public InsertAllRequest.Builder rows(Iterable<InsertAllRequest.RowToInsert> rows)

Sets the rows to insert as a list of InsertAllRequest.RowToInsert objects.

addRow

public InsertAllRequest.Builder addRow(InsertAllRequest.RowToInsert rowToInsert)

Adds a row to be inserted.

addRow

public InsertAllRequest.Builder addRow(String id,
                              Map<String,Object> content)

Adds a row to be inserted with associated id.

Example usage of adding a row with associated id:

 InsertAllRequest.Builder builder = InsertAllRequest.builder(tableId);
 List<Long> repeatedFieldValue = Arrays.asList(1L, 2L);
 Map<String, Object> recordContent = new HashMap<String, Object>();
 recordContent.put("subfieldName1", "value");
 recordContent.put("subfieldName2", repeatedFieldValue);
 Map<String, Object> rowContent = new HashMap<String, Object>();
 rowContent.put("fieldName1", true);
 rowContent.put("fieldName2", recordContent);
 builder.addRow("rowId", rowContent);
 

addRow

public InsertAllRequest.Builder addRow(Map<String,Object> content)

Adds a row to be inserted without an associated id.

Example usage of adding a row without an associated id:

 InsertAllRequest.Builder builder = InsertAllRequest.builder(tableId);
 List<Long> repeatedFieldValue = Arrays.asList(1L, 2L);
 Map<String, Object> recordContent = new HashMap<String, Object>();
 recordContent.put("subfieldName1", "value");
 recordContent.put("subfieldName2", repeatedFieldValue);
 Map<String, Object> rowContent = new HashMap<String, Object>();
 rowContent.put("fieldName1", true);
 rowContent.put("fieldName2", recordContent);
 builder.addRow(rowContent);
 

skipInvalidRows

public InsertAllRequest.Builder skipInvalidRows(boolean skipInvalidRows)

Sets whether to insert all valid rows of a request, even if invalid rows exist. If not set the entire insert request will fail if it contains an invalid row.

ignoreUnknownValues

public InsertAllRequest.Builder ignoreUnknownValues(boolean ignoreUnknownValues)

Sets whether to accept rows that contain values that do not match the schema. The unknown values are ignored. If not set, rows with unknown values are considered to be invalid.

templateSuffix

public InsertAllRequest.Builder templateSuffix(String templateSuffix)

If specified, the destination table is treated as a base template. Rows are inserted into an instance table named "{destination}{templateSuffix}". BigQuery will manage the creation of the instance table, using the schema of the base template table. Table creation might take some time. To obtain table's information after BigQuery.insertAll(InsertAllRequest) is called use:

 String suffixTableId = ...;
 TableInfo suffixTable = bigquery.getTable(DATASET, suffixTableId);
 while (suffixTable == null) {
   Thread.sleep(1000L);
   suffixTable = bigquery.getTable(DATASET, suffixTableId);
 }

See Also:

Template Tables

build

public InsertAllRequest build()