org.apache.beam.sdk.extensions.sql

Interface BeamSqlTable

All Known Implementing Classes:

BaseBeamTable, BeamBigQueryTable, BeamKafkaCSVTable, BeamKafkaTable, BeamPCollectionTable, TestBoundedTable, TestTable, TestUnboundedTable, TextTable

public interface BeamSqlTable

This interface defines a Beam Sql Table.

Method Summary

Modifier and Type	Method and Description
PCollection<Row>	buildIOReader(PBegin begin) create a PCollection<Row> from source.
POutput	buildIOWriter(PCollection<Row> input) create a IO.write() instance to write to target.
Schema	getSchema() Get the schema info of the table.

Method Detail

buildIOReader

PCollection<Row> buildIOReader(PBegin begin)

create a PCollection<Row> from source.

buildIOWriter

POutput buildIOWriter(PCollection<Row> input)

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

getSchema

Schema getSchema()

Get the schema info of the table.