org.apache.flink.sql.tests

Class BatchSQLTestProgram.GeneratorTableSource

java.lang.Object

org.apache.flink.table.sources.InputFormatTableSource<Row>

org.apache.flink.sql.tests.BatchSQLTestProgram.GeneratorTableSource

All Implemented Interfaces:

StreamTableSource<Row>, TableSource<Row>

Enclosing class:

BatchSQLTestProgram

public static class BatchSQLTestProgram.GeneratorTableSource
extends InputFormatTableSource<Row>

TableSource for generated data.

Method Summary

Modifier and Type	Method and Description
InputFormat<Row,?>	getInputFormat() Returns an InputFormat for reading the data of the table.
DataType	getProducedDataType() Returns the DataType for the produced data of the TableSource.
TableSchema	getTableSchema() Returns the schema of the produced table.

Methods inherited from class org.apache.flink.table.sources.InputFormatTableSource

getDataStream, isBounded

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.sources.TableSource

explainSource, getReturnType

Method Detail

getInputFormat

public InputFormat<Row,?> getInputFormat()

Description copied from class: InputFormatTableSource

Returns an InputFormat for reading the data of the table.

Specified by:

getInputFormat in class InputFormatTableSource<Row>

getProducedDataType

public DataType getProducedDataType()

Description copied from interface: TableSource

Returns the DataType for the produced data of the TableSource.

Returns:

The data type of the returned DataStream.

getTableSchema

public TableSchema getTableSchema()

Description copied from interface: TableSource

Returns the schema of the produced table.

Returns:

The TableSchema of the produced table.