@Experimental public class BigtableTable extends SchemaBaseBeamTable implements java.io.Serializable
schema
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_26_0.org.apache.calcite.rex.RexNode> filter)
Generate an IO implementation of
BeamSqlTableFilter for predicate push-down. |
BeamTableStatistics |
getTableStatistics(PipelineOptions options)
Estimates the number of rows or the rate for unbounded Tables.
|
PCollection.IsBounded |
isBounded()
Whether this table is bounded (known to be finite) or unbounded (may or may not be finite).
|
getSchema
supportsProjects
public PCollection<Row> buildIOReader(PBegin begin)
BeamSqlTable
PCollection<Row>
from source.buildIOReader
in interface BeamSqlTable
public PCollection<Row> buildIOReader(PBegin begin, BeamSqlTableFilter filters, java.util.List<java.lang.String> fieldNames)
BeamSqlTable
PCollection<Row>
from source with predicate and/or project pushed-down.buildIOReader
in interface BeamSqlTable
buildIOReader
in class BaseBeamTable
public POutput buildIOWriter(PCollection<Row> input)
BeamSqlTable
IO.write()
instance to write to target.buildIOWriter
in interface BeamSqlTable
public PCollection.IsBounded isBounded()
BeamSqlTable
isBounded
in interface BeamSqlTable
public BeamTableStatistics getTableStatistics(PipelineOptions options)
BeamSqlTable
getTableStatistics
in interface BeamSqlTable
public BeamSqlTableFilter constructFilter(java.util.List<org.apache.beam.vendor.calcite.v1_26_0.org.apache.calcite.rex.RexNode> filter)
BeamSqlTable
BeamSqlTableFilter
for predicate push-down.constructFilter
in interface BeamSqlTable
constructFilter
in class BaseBeamTable