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(TableReference tableReference, @Nullable String tableDescription)
TableDestination(TableReference tableReference, @Nullable String tableDescription, TimePartitioning timePartitioning)
TableDestination(TableReference tableReference, @Nullable String tableDescription, @Nullable String jsonTimePartitioning)
TableDestination(TableReference tableReference, @Nullable String tableDescription, @Nullable String jsonTimePartitioning, @Nullable String jsonClustering)
TableDestination(String tableSpec, @Nullable String tableDescription)
TableDestination(String tableSpec, @Nullable String tableDescription, @Nullable TimePartitioning timePartitioning, Clustering clustering)
TableDestination(String tableSpec, @Nullable String tableDescription, 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 Clustering	getClustering()
@Nullable String	getJsonClustering()
@Nullable String	getJsonTimePartitioning()
String	getShortTableUrn()	Return shortened tablespec in datasets/[dataset]/tables/[table] format.
@Nullable String	getTableDescription()
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 TimePartitioning	getTimePartitioning()
int	hashCode()
String	toString()
TableDestination	withTableReference(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(TableReference tableReference,
 @Nullable String tableDescription)

TableDestination

public TableDestination(TableReference tableReference,
 @Nullable String tableDescription,
 TimePartitioning timePartitioning)

TableDestination

public TableDestination(String tableSpec,
 @Nullable String tableDescription,
 TimePartitioning timePartitioning)

TableDestination

public TableDestination(String tableSpec,
 @Nullable String tableDescription,
 @Nullable TimePartitioning timePartitioning,
 Clustering clustering)

TableDestination

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

TableDestination

public TableDestination(TableReference tableReference,
 @Nullable String tableDescription,
 @Nullable String jsonTimePartitioning)

TableDestination

public TableDestination(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(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 TableReference getTableReference()

getJsonTimePartitioning

public @Nullable String getJsonTimePartitioning()

getTimePartitioning

public @Nullable TimePartitioning getTimePartitioning()

getJsonClustering

public @Nullable String getJsonClustering()

getClustering

public @Nullable 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