public class AvroTable extends SchemaBaseBeamTable implements java.io.Serializable
AvroTable
is a BeamSqlTable
.schema
Constructor and Description |
---|
AvroTable(java.lang.String tableName,
Schema beamSchema,
java.lang.String filePattern) |
Modifier and Type | Method and Description |
---|---|
PCollection<Row> |
buildIOReader(PBegin begin)
create a
PCollection<Row> from source. |
PDone |
buildIOWriter(PCollection<Row> input)
create a
IO.write() instance to write to target. |
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
buildIOReader, constructFilter, supportsProjects
public AvroTable(java.lang.String tableName, Schema beamSchema, java.lang.String filePattern)
public PCollection<Row> buildIOReader(PBegin begin)
BeamSqlTable
PCollection<Row>
from source.buildIOReader
in interface BeamSqlTable
public PDone 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