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
- See Also:
-
Field Summary
Fields inherited from class org.apache.beam.sdk.extensions.sql.meta.SchemaBaseBeamTable
schema
-
Method Summary
Modifier and TypeMethodDescriptionbuildIOReader
(PBegin begin) create aPCollection<Row>
from source.buildIOReader
(PBegin begin, BeamSqlTableFilter filters, List<String> fieldNames) create aPCollection<Row>
from source with predicate and/or project pushed-down.buildIOWriter
(PCollection<Row> input) create aIO.write()
instance to write to target.constructFilter
(List<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rex.RexNode> filter) Generate an IO implementation ofBeamSqlTableFilter
for predicate push-down.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
-
Method Details
-
buildIOReader
Description copied from interface:BeamSqlTable
create aPCollection<Row>
from source.- Specified by:
buildIOReader
in interfaceBeamSqlTable
-
buildIOReader
public PCollection<Row> buildIOReader(PBegin begin, BeamSqlTableFilter filters, List<String> fieldNames) Description copied from interface:BeamSqlTable
create aPCollection<Row>
from source with predicate and/or project pushed-down.- Specified by:
buildIOReader
in interfaceBeamSqlTable
- Overrides:
buildIOReader
in classBaseBeamTable
-
buildIOWriter
Description copied from interface:BeamSqlTable
create aIO.write()
instance to write to target.- Specified by:
buildIOWriter
in interfaceBeamSqlTable
-
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 interfaceBeamSqlTable
-
constructFilter
public BeamSqlTableFilter constructFilter(List<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.rex.RexNode> filter) Description copied from interface:BeamSqlTable
Generate an IO implementation ofBeamSqlTableFilter
for predicate push-down.- Specified by:
constructFilter
in interfaceBeamSqlTable
- Overrides:
constructFilter
in classBaseBeamTable
-