com.google.cloud.bigquery

Class Table

java.lang.Object

com.google.cloud.bigquery.TableInfo

com.google.cloud.bigquery.Table

All Implemented Interfaces:

Serializable

public class Table
extends TableInfo

A Google BigQuery Table.

Objects of this class are immutable. Operations that modify the table like update(com.google.cloud.bigquery.BigQuery.TableOption...) return a new object. To get a Table object with the most recent information use reload(com.google.cloud.bigquery.BigQuery.TableOption...). Table adds a layer of service-related functionality over TableInfo.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Table.Builder A builder for Table objects.

Method Summary

Methods

Modifier and Type	Method and Description
BigQuery	bigquery() Returns the table's BigQuery object used to issue requests.
Job	copy(String destinationDataset, String destinationTable, BigQuery.JobOption... options) Starts a BigQuery Job to copy the current table to the provided destination table.
Job	copy(TableId destinationTable, BigQuery.JobOption... options) Starts a BigQuery Job to copy the current table to the provided destination table.
boolean	delete() Deletes this table.
boolean	equals(Object obj)
boolean	exists() Checks if this table exists.
Job	extract(String format, List<String> destinationUris, BigQuery.JobOption... options) Starts a BigQuery Job to extract the current table to the provided destination URIs.
Job	extract(String format, String destinationUri, BigQuery.JobOption... options) Starts a BigQuery Job to extract the current table to the provided destination URI.
int	hashCode()
InsertAllResponse	insert(Iterable<InsertAllRequest.RowToInsert> rows) Insert rows into the table.
InsertAllResponse	insert(Iterable<InsertAllRequest.RowToInsert> rows, boolean skipInvalidRows, boolean ignoreUnknownValues) Insert rows into the table.
Page<List<FieldValue>>	list(BigQuery.TableDataListOption... options) Returns the paginated list rows in this table.
Job	load(FormatOptions format, List<String> sourceUris, BigQuery.JobOption... options) Starts a BigQuery Job to load data into the current table from the provided source URIs.
Job	load(FormatOptions format, String sourceUri, BigQuery.JobOption... options) Starts a BigQuery Job to load data into the current table from the provided source URI.
Table	reload(BigQuery.TableOption... options) Fetches current table's latest information.
Table.Builder	toBuilder() Returns a builder for the table object.
Table	update(BigQuery.TableOption... options) Updates the table's information with this table's information.

Methods inherited from class com.google.cloud.bigquery.TableInfo

builder, creationTime, definition, description, etag, expirationTime, friendlyName, generatedId, lastModifiedTime, of, selfLink, tableId, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

exists

public boolean exists()

Checks if this table exists.

Returns:

true if this table exists, false otherwise

Throws:

BigQueryException - upon failure

reload

public Table reload(BigQuery.TableOption... options)

Fetches current table's latest information. Returns null if the table does not exist.

Parameters:

options - table options

Returns:

a Table object with latest information or null if not found

Throws:

BigQueryException - upon failure

update

public Table update(BigQuery.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 Table object is returned.

Parameters:

options - dataset options

Returns:

a Table object with updated information

Throws:

BigQueryException - upon failure

delete

public boolean delete()

Deletes this table.

Returns:

true if table was deleted, false if it was not found

Throws:

BigQueryException - upon failure

insert

public InsertAllResponse insert(Iterable<InsertAllRequest.RowToInsert> rows)
                         throws BigQueryException

Insert rows into the table.

Parameters:

rows - rows to be inserted

Throws:

BigQueryException - upon failure

insert

public InsertAllResponse insert(Iterable<InsertAllRequest.RowToInsert> rows,
                       boolean skipInvalidRows,
                       boolean ignoreUnknownValues)
                         throws BigQueryException

Insert rows into the table.

Parameters:

rows - rows to be inserted

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

ignoreUnknownValues - 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

Throws:

BigQueryException - upon failure

list

public Page<List<FieldValue>> list(BigQuery.TableDataListOption... options)
                            throws BigQueryException

Returns the paginated list rows in this table.

Parameters:

options - table data list options

Throws:

BigQueryException - upon failure

copy

public Job copy(String destinationDataset,
       String destinationTable,
       BigQuery.JobOption... options)
         throws BigQueryException

Starts a BigQuery Job to copy the current table to the provided destination table. Returns the started Job object.

Parameters:

destinationDataset - the user-defined id of the destination dataset

destinationTable - the user-defined id of the destination table

options - job options

Throws:

BigQueryException - upon failure

copy

public Job copy(TableId destinationTable,
       BigQuery.JobOption... options)
         throws BigQueryException

Starts a BigQuery Job to copy the current table to the provided destination table. Returns the started Job object.

Parameters:

destinationTable - the destination table of the copy job

options - job options

Throws:

BigQueryException - upon failure

extract

public Job extract(String format,
          String destinationUri,
          BigQuery.JobOption... options)
            throws BigQueryException

Starts a BigQuery Job to extract the current table to the provided destination URI. Returns the started Job object.

Parameters:

format - the format of the extracted data

destinationUri - the fully-qualified Google Cloud Storage URI (e.g. gs://bucket/path) where the extracted table should be written

options - job options

Throws:

BigQueryException - upon failure

extract

public Job extract(String format,
          List<String> destinationUris,
          BigQuery.JobOption... options)
            throws BigQueryException

Starts a BigQuery Job to extract the current table to the provided destination URIs. Returns the started Job object.

Parameters:

format - the format of the exported data

destinationUris - the fully-qualified Google Cloud Storage URIs (e.g. gs://bucket/path) where the extracted table should be written

options - job options

Throws:

BigQueryException - upon failure

load

public Job load(FormatOptions format,
       String sourceUri,
       BigQuery.JobOption... options)
         throws BigQueryException

Starts a BigQuery Job to load data into the current table from the provided source URI. Returns the started Job object.

Parameters:

format - the format of the data to load

sourceUri - the fully-qualified Google Cloud Storage URI (e.g. gs://bucket/path) from which to load the data

options - job options

Throws:

BigQueryException - upon failure

load

public Job load(FormatOptions format,
       List<String> sourceUris,
       BigQuery.JobOption... options)
         throws BigQueryException

Starts a BigQuery Job to load data into the current table from the provided source URIs. Returns the started Job object.

Parameters:

format - the format of the exported data

sourceUris - the fully-qualified Google Cloud Storage URIs (e.g. gs://bucket/path) from which to load the data

options - job options

Throws:

BigQueryException - upon failure

bigquery

public BigQuery bigquery()

Returns the table's BigQuery object used to issue requests.

toBuilder

public Table.Builder toBuilder()

Description copied from class: TableInfo

Returns a builder for the table object.

Overrides:

toBuilder in class TableInfo

equals

public final boolean equals(Object obj)

Overrides:

equals in class TableInfo

hashCode

public final int hashCode()

Overrides:

hashCode in class TableInfo