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

Class TestTable

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

All Implemented Interfaces:

java.io.Serializable, BeamSqlTable

Direct Known Subclasses:

TestBoundedTable, TestUnboundedTable

public abstract class TestTable
extends SchemaBaseBeamTable

Base class for mocked table.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.concurrent.atomic.AtomicInteger	COUNTER

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

schema

Constructor Summary

Constructors

Constructor and Description
TestTable(Schema beamSchema)

Method Summary

Modifier and Type	Method and Description
POutput	buildIOWriter(PCollection<Row> input) create a IO.write() instance to write to target.

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, getTableStatistics, supportsProjects

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.beam.sdk.extensions.sql.meta.BeamSqlTable

buildIOReader, isBounded

Field Detail

COUNTER

public static final java.util.concurrent.atomic.AtomicInteger COUNTER

Constructor Detail

TestTable

public TestTable(Schema beamSchema)

Method Detail

buildIOWriter

public POutput buildIOWriter(PCollection<Row> input)

Description copied from interface: BeamSqlTable

create a IO.write() instance to write to target.