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

Class TableDestination

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable

public class TableDestination
extends java.lang.Object
implements java.io.Serializable

Encapsulates a BigQuery table destination.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TableDestination(java.lang.String tableSpec, @Nullable java.lang.String tableDescription)
TableDestination(java.lang.String tableSpec, @Nullable java.lang.String tableDescription, @Nullable java.lang.String jsonTimePartitioning)
TableDestination(java.lang.String tableSpec, @Nullable java.lang.String tableDescription, @Nullable java.lang.String jsonTimePartitioning, @Nullable java.lang.String jsonClustering)
TableDestination(java.lang.String tableSpec, @Nullable java.lang.String tableDescription, TimePartitioning timePartitioning)
TableDestination(java.lang.String tableSpec, @Nullable java.lang.String tableDescription, TimePartitioning timePartitioning, Clustering clustering)
TableDestination(TableReference tableReference, @Nullable java.lang.String tableDescription)
TableDestination(TableReference tableReference, @Nullable java.lang.String tableDescription, @Nullable java.lang.String jsonTimePartitioning)
TableDestination(TableReference tableReference, @Nullable java.lang.String tableDescription, @Nullable java.lang.String jsonTimePartitioning, @Nullable java.lang.String jsonClustering)
TableDestination(TableReference tableReference, @Nullable java.lang.String tableDescription, TimePartitioning timePartitioning)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

TableDestination

public TableDestination(java.lang.String tableSpec,
                        @Nullable java.lang.String tableDescription)

TableDestination

public TableDestination(TableReference tableReference,
                        @Nullable java.lang.String tableDescription)

TableDestination

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

TableDestination

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

TableDestination

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

TableDestination

public TableDestination(java.lang.String tableSpec,
                        @Nullable java.lang.String tableDescription,
                        @Nullable java.lang.String jsonTimePartitioning)

TableDestination

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

TableDestination

public TableDestination(TableReference tableReference,
                        @Nullable java.lang.String tableDescription,
                        @Nullable java.lang.String jsonTimePartitioning,
                        @Nullable java.lang.String jsonClustering)

TableDestination

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

Method Detail

withTableReference

public TableDestination withTableReference(TableReference tableReference)

getTableSpec

public java.lang.String getTableSpec()

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

getTableUrn

public java.lang.String getTableUrn(BigQueryOptions bigQueryOptions)

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

getShortTableUrn

public java.lang.String getShortTableUrn()

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

getTableReference

public TableReference getTableReference()

getJsonTimePartitioning

public @Nullable java.lang.String getJsonTimePartitioning()

getTimePartitioning

public @Nullable TimePartitioning getTimePartitioning()

getJsonClustering

public @Nullable java.lang.String getJsonClustering()

getClustering

public @Nullable Clustering getClustering()

getTableDescription

public @Nullable java.lang.String getTableDescription()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

equals

public boolean equals(@Nullable java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object