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:

java.io.Serializable, BeamSqlTable

public class BigtableTable
extends SchemaBaseBeamTable
implements java.io.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 and Description
PCollection<Row>	buildIOReader(PBegin begin) create a PCollection<Row> from source.
PCollection<Row>	buildIOReader(PBegin begin, BeamSqlTableFilter filters, java.util.List<java.lang.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(java.util.List<org.apache.beam.vendor.calcite.v1_28_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 Detail

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,
                                      java.util.List<java.lang.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(java.util.List<org.apache.beam.vendor.calcite.v1_28_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