org.apache.beam.sdk.extensions.sql.meta.provider.bigquery

Class BeamBigQueryTable

java.lang.Object

org.apache.beam.sdk.extensions.sql.impl.schema.BaseBeamTable

org.apache.beam.sdk.extensions.sql.meta.provider.bigquery.BeamBigQueryTable

All Implemented Interfaces:

java.io.Serializable, BeamSqlTable

@Experimental
public class BeamBigQueryTable
extends BaseBeamTable
implements java.io.Serializable

BeamBigQueryTable represent a BigQuery table as a target. This provider does not currently support being a source.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.beam.sdk.extensions.sql.impl.schema.BaseBeamTable

schema

Constructor Summary

Constructors

Constructor and Description
BeamBigQueryTable(Schema beamSchema, java.lang.String tableSpec)

Method Summary

Modifier and Type	Method and Description
PCollection<Row>	buildIOReader(Pipeline pipeline) create a PCollection<BeamSqlRow> from source.
PTransform<? super PCollection<Row>,POutput>	buildIOWriter() create a IO.write() instance to write to target.
BeamIOType	getSourceType() In Beam SQL, there's no difference between a batch query and a streaming query.

Methods inherited from class org.apache.beam.sdk.extensions.sql.impl.schema.BaseBeamTable

getSchema

Methods inherited from class java.lang.Object

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

Constructor Detail

BeamBigQueryTable

public BeamBigQueryTable(Schema beamSchema,
                         java.lang.String tableSpec)

Method Detail

getSourceType

public BeamIOType getSourceType()

Description copied from interface: BeamSqlTable

In Beam SQL, there's no difference between a batch query and a streaming query. BeamIOType is used to validate the sources.

Specified by:

getSourceType in interface BeamSqlTable

buildIOReader

public PCollection<Row> buildIOReader(Pipeline pipeline)

Description copied from interface: BeamSqlTable

create a PCollection<BeamSqlRow> from source.

Specified by:

buildIOReader in interface BeamSqlTable

buildIOWriter

public PTransform<? super PCollection<Row>,POutput> buildIOWriter()

Description copied from interface: BeamSqlTable

create a IO.write() instance to write to target.

Specified by:

buildIOWriter in interface BeamSqlTable