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

Class TestTable

java.lang.Object

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

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

All Implemented Interfaces:

java.io.Serializable, BeamSqlTable

Direct Known Subclasses:

TestBoundedTable, TestUnboundedTable

@Experimental
public abstract class TestTable
extends BaseBeamTable

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

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

getSchema

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

buildIOReader, getTableStatistics, 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.