Package org.apache.beam.sdk.extensions.sql.meta.provider.datagen

Class DataGeneratorTable

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.datagen.DataGeneratorTable

All Implemented Interfaces:

Serializable, BeamSqlTable

public class DataGeneratorTable
extends SchemaBaseBeamTable

Represents a 'datagen' table within a Beam SQL pipeline. This class extends SchemaBaseBeamTable to correctly implement the full BeamSqlTable interface.

See Also:

• Serialized Form

Field Summary

Fields inherited from class org.apache.beam.sdk.extensions.sql.meta.SchemaBaseBeamTable

schema

Constructor Summary

Constructors

Constructor	Description
DataGeneratorTable(Schema schema, ObjectNode properties)

Method Summary

Modifier and Type	Method	Description
PCollection<Row>	buildIOReader(PBegin begin)	create a PCollection<Row> from source.
PCollection<Row>	buildIOReader(PBegin begin, BeamSqlTableFilter filters, List<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.
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).

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

constructFilter, supportsProjects

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DataGeneratorTable

public DataGeneratorTable(Schema schema,
 ObjectNode properties)

Method Details

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).

buildIOReader

public PCollection<Row> buildIOReader(PBegin begin)

Description copied from interface: BeamSqlTable

create a PCollection<Row> from source.

buildIOReader

public PCollection<Row> buildIOReader(PBegin begin,
 BeamSqlTableFilter filters,
 List<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.

getTableStatistics

public BeamTableStatistics getTableStatistics(PipelineOptions options)

Description copied from interface: BeamSqlTable

Estimates the number of rows or the rate for unbounded Tables. If it is not possible to estimate the row count or rate it will return BeamTableStatistics.BOUNDED_UNKNOWN.

Specified by:

getTableStatistics in interface BeamSqlTable

Overrides:

getTableStatistics in class BaseBeamTable