Package org.apache.beam.sdk.extensions.sql.meta.provider.bigtable

Class BigtableTable

java.lang.Object

org.apache.beam.sdk.extensions.sql.meta.BaseBeamTable

org.apache.beam.sdk.extensions.sql.meta.SchemaBaseBeamTable

org.apache.beam.sdk.extensions.sql.meta.provider.bigtable.BigtableTable

All Implemented Interfaces:

Serializable, BeamSqlTable

public class BigtableTable
extends SchemaBaseBeamTable
implements Serializable

See Also:

• Serialized Form

Field Summary

Fields inherited from class org.apache.beam.sdk.extensions.sql.meta.SchemaBaseBeamTable

schema

Method Summary

Modifier and Type	Method	Description
PCollection<Row>	buildIOReader(PBegin begin)	create a PCollection<Row> from source.
PCollection<Row>	buildIOReader(PBegin begin, BeamSqlTableFilter filters, List<String> fieldNames)	create a PCollection<Row> from source with predicate and/or project pushed-down.
POutput	buildIOWriter(PCollection<Row> input)	create a IO.write() instance to write to target.
BeamSqlTableFilter	constructFilter(List<org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rex.RexNode> filter)	Generate an IO implementation of BeamSqlTableFilter for predicate push-down.
PCollection.IsBounded	isBounded()	Whether this table is bounded (known to be finite) or unbounded (may or may not be finite).

Methods inherited from class org.apache.beam.sdk.extensions.sql.meta.SchemaBaseBeamTable

getSchema

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

getTableStatistics, supportsProjects

Methods inherited from class java.lang.Object

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

Method Details

buildIOReader

public PCollection<Row> buildIOReader(PBegin begin)

Description copied from interface: BeamSqlTable

create a PCollection<Row> from source.

Specified by:

buildIOReader in interface BeamSqlTable

buildIOReader

public PCollection<Row> buildIOReader(PBegin begin,
 BeamSqlTableFilter filters,
 List<String> fieldNames)

Description copied from interface: BeamSqlTable

create a PCollection<Row> from source with predicate and/or project pushed-down.

Specified by:

buildIOReader in interface BeamSqlTable

Overrides:

buildIOReader in class BaseBeamTable

buildIOWriter

public POutput buildIOWriter(PCollection<Row> input)

Description copied from interface: BeamSqlTable

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

Specified by:

buildIOWriter in interface BeamSqlTable

isBounded

public PCollection.IsBounded isBounded()

Description copied from interface: BeamSqlTable

Whether this table is bounded (known to be finite) or unbounded (may or may not be finite).

Specified by:

isBounded in interface BeamSqlTable

constructFilter

public BeamSqlTableFilter constructFilter(List<org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.rex.RexNode> filter)

Description copied from interface: BeamSqlTable

Generate an IO implementation of BeamSqlTableFilter for predicate push-down.

Specified by:

constructFilter in interface BeamSqlTable

Overrides:

constructFilter in class BaseBeamTable