@Experimental public class MongoDbTable extends SchemaBaseBeamTable implements java.io.Serializable
Modifier and Type | Class and Description |
---|---|
static class |
MongoDbTable.DocumentToRow |
static class |
MongoDbTable.RowToDocument |
schema
Modifier and Type | Method and Description |
---|---|
PCollection<Row> |
buildIOReader(PBegin begin)
create a
PCollection<Row> from source. |
POutput |
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 PCollection<Row> buildIOReader(PBegin begin)
BeamSqlTable
PCollection<Row>
from source.buildIOReader
in interface BeamSqlTable
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