org.apache.beam.sdk.extensions.sql.meta.provider.test

Class TestUnboundedTable

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.test.TestTable

org.apache.beam.sdk.extensions.sql.meta.provider.test.TestUnboundedTable

All Implemented Interfaces:

java.io.Serializable, BeamSqlTable

public class TestUnboundedTable
extends TestTable

A mocked unbounded table.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.beam.sdk.extensions.sql.meta.provider.test.TestTable

COUNTER

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

schema

Method Summary

Modifier and Type	Method and Description
TestUnboundedTable	addRows(Duration duration, java.lang.Object... args) Add rows to the builder.
PCollection<Row>	buildIOReader(PBegin begin) create a PCollection<Row> from source.
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).
static TestUnboundedTable	of(java.lang.Object... args) Convenient way to build a mocked unbounded table.
TestUnboundedTable	setStatistics(BeamTableStatistics statistics)
TestUnboundedTable	timestampColumnIndex(int idx)

Methods inherited from class org.apache.beam.sdk.extensions.sql.meta.provider.test.TestTable

buildIOWriter

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

buildIOReader, constructFilter, supportsProjects

Methods inherited from class java.lang.Object

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

Method Detail

of

public static TestUnboundedTable of(java.lang.Object... args)

Convenient way to build a mocked unbounded table.

e.g.

 TestUnboundedTable
   .of(Types.BIGINT, "order_id",
       Types.INTEGER, "site_id",
       Types.DOUBLE, "price",
       Types.TIMESTAMP, "order_time")
 

setStatistics

public TestUnboundedTable setStatistics(BeamTableStatistics statistics)

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

timestampColumnIndex

public TestUnboundedTable timestampColumnIndex(int idx)

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

addRows

public TestUnboundedTable addRows(Duration duration,
                                  java.lang.Object... args)

Add rows to the builder.

Sample usage:

 addRows(
   duration,      -- duration which stands for the corresponding watermark instant
   1, 3, "james", -- first row
   2, 5, "bond"   -- second row
   ...
 )
 

buildIOReader

public PCollection<Row> buildIOReader(PBegin begin)

Description copied from interface: BeamSqlTable

create a PCollection<Row> from source.