Package 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:

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	Description
static final AtomicInteger	COUNTER

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

schema

Constructor Summary

Constructors

Constructor	Description
TestTable(Schema beamSchema)

Method Summary

Modifier and Type	Method	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 Details

COUNTER

public static final AtomicInteger COUNTER

Constructor Details

TestTable

public TestTable(Schema beamSchema)

Method Details

buildIOWriter

public POutput buildIOWriter(PCollection<Row> input)

Description copied from interface: BeamSqlTable

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