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

Class TestUnboundedTable

java.lang.Object

org.apache.beam.sdk.extensions.sql.impl.schema.BaseBeamTable

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

@Experimental
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.impl.schema.BaseBeamTable

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.
static TestUnboundedTable	of(java.lang.Object... args) Convenient way to build a mocked unbounded table.
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.impl.schema.BaseBeamTable

getSchema

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

timestampColumnIndex

public TestUnboundedTable timestampColumnIndex(int idx)

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.