Package org.apache.beam.sdk.io.gcp.bigquery

Class TableDestination

java.lang.Object

org.apache.beam.sdk.io.gcp.bigquery.TableDestination

All Implemented Interfaces:

Serializable

public class TableDestination
extends Object
implements Serializable

Encapsulates a BigQuery table destination.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
TableDestination(com.google.api.services.bigquery.model.TableReference tableReference, @Nullable String tableDescription)
TableDestination(com.google.api.services.bigquery.model.TableReference tableReference, @Nullable String tableDescription, com.google.api.services.bigquery.model.TimePartitioning timePartitioning)
TableDestination(com.google.api.services.bigquery.model.TableReference tableReference, @Nullable String tableDescription, @Nullable String jsonTimePartitioning)
TableDestination(com.google.api.services.bigquery.model.TableReference tableReference, @Nullable String tableDescription, @Nullable String jsonTimePartitioning, @Nullable String jsonClustering)
TableDestination(String tableSpec, @Nullable String tableDescription)
TableDestination(String tableSpec, @Nullable String tableDescription, @Nullable com.google.api.services.bigquery.model.TimePartitioning timePartitioning, com.google.api.services.bigquery.model.Clustering clustering)
TableDestination(String tableSpec, @Nullable String tableDescription, com.google.api.services.bigquery.model.TimePartitioning timePartitioning)
TableDestination(String tableSpec, @Nullable String tableDescription, @Nullable String jsonTimePartitioning)
TableDestination(String tableSpec, @Nullable String tableDescription, @Nullable String jsonTimePartitioning, @Nullable String jsonClustering)

Method Summary

Modifier and Type	Method	Description
boolean	equals(@Nullable Object o)
@Nullable com.google.api.services.bigquery.model.Clustering	getClustering()
@Nullable String	getJsonClustering()
@Nullable String	getJsonTimePartitioning()
String	getShortTableUrn()	Return shortened tablespec in datasets/[dataset]/tables/[table] format.
@Nullable String	getTableDescription()
com.google.api.services.bigquery.model.TableReference	getTableReference()
String	getTableSpec()	Return the tablespec in [project:].dataset.tableid format.
String	getTableUrn(BigQueryOptions bigQueryOptions)	Return the tablespec in projects/[project]/datasets/[dataset]/tables/[table] format.
@Nullable com.google.api.services.bigquery.model.TimePartitioning	getTimePartitioning()
int	hashCode()
String	toString()
TableDestination	withTableReference(com.google.api.services.bigquery.model.TableReference tableReference)

Methods inherited from class java.lang.Object

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

Constructor Details

TableDestination

public TableDestination(String tableSpec,
 @Nullable String tableDescription)

TableDestination

public TableDestination(com.google.api.services.bigquery.model.TableReference tableReference,
 @Nullable String tableDescription)

TableDestination

public TableDestination(com.google.api.services.bigquery.model.TableReference tableReference,
 @Nullable String tableDescription,
 com.google.api.services.bigquery.model.TimePartitioning timePartitioning)

TableDestination

public TableDestination(String tableSpec,
 @Nullable String tableDescription,
 com.google.api.services.bigquery.model.TimePartitioning timePartitioning)

TableDestination

public TableDestination(String tableSpec,
 @Nullable String tableDescription,
 @Nullable com.google.api.services.bigquery.model.TimePartitioning timePartitioning,
 com.google.api.services.bigquery.model.Clustering clustering)

TableDestination

public TableDestination(String tableSpec,
 @Nullable String tableDescription,
 @Nullable String jsonTimePartitioning)

TableDestination

public TableDestination(com.google.api.services.bigquery.model.TableReference tableReference,
 @Nullable String tableDescription,
 @Nullable String jsonTimePartitioning)

TableDestination

public TableDestination(com.google.api.services.bigquery.model.TableReference tableReference,
 @Nullable String tableDescription,
 @Nullable String jsonTimePartitioning,
 @Nullable String jsonClustering)

TableDestination

public TableDestination(String tableSpec,
 @Nullable String tableDescription,
 @Nullable String jsonTimePartitioning,
 @Nullable String jsonClustering)

Method Details

withTableReference

public TableDestination withTableReference(com.google.api.services.bigquery.model.TableReference tableReference)

getTableSpec

public String getTableSpec()

Return the tablespec in [project:].dataset.tableid format.

getTableUrn

public String getTableUrn(BigQueryOptions bigQueryOptions)

Return the tablespec in projects/[project]/datasets/[dataset]/tables/[table] format.

getShortTableUrn

public String getShortTableUrn()

Return shortened tablespec in datasets/[dataset]/tables/[table] format.

getTableReference

public com.google.api.services.bigquery.model.TableReference getTableReference()

getJsonTimePartitioning

public @Nullable String getJsonTimePartitioning()

getTimePartitioning

public @Nullable com.google.api.services.bigquery.model.TimePartitioning getTimePartitioning()

getJsonClustering

public @Nullable String getJsonClustering()

getClustering

public @Nullable com.google.api.services.bigquery.model.Clustering getClustering()

getTableDescription

public @Nullable String getTableDescription()

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(@Nullable Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object