org.apache.flink.sql.tests

Class StreamSQLTestProgram.GeneratorTableSource

java.lang.Object

org.apache.flink.sql.tests.StreamSQLTestProgram.GeneratorTableSource

All Implemented Interfaces:

org.apache.flink.table.sources.DefinedFieldMapping, org.apache.flink.table.sources.DefinedRowtimeAttributes, org.apache.flink.table.sources.StreamTableSource<Row>, org.apache.flink.table.sources.TableSource<Row>

Enclosing class:

StreamSQLTestProgram

public static class StreamSQLTestProgram.GeneratorTableSource
extends Object
implements org.apache.flink.table.sources.StreamTableSource<Row>, org.apache.flink.table.sources.DefinedRowtimeAttributes, org.apache.flink.table.sources.DefinedFieldMapping

TableSource for generated data.

Constructor Summary

Constructors

Constructor and Description
GeneratorTableSource(int numKeys, float recordsPerKeyAndSecond, int durationSeconds, int offsetSeconds)

Method Summary

Modifier and Type	Method and Description
String	explainSource()
DataStream<Row>	getDataStream(StreamExecutionEnvironment execEnv)
Map<String,String>	getFieldMapping()
TypeInformation<Row>	getReturnType()
List<org.apache.flink.table.sources.RowtimeAttributeDescriptor>	getRowtimeAttributeDescriptors()
org.apache.flink.table.api.TableSchema	getTableSchema()

Methods inherited from class java.lang.Object

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

Constructor Detail

GeneratorTableSource

public GeneratorTableSource(int numKeys,
                            float recordsPerKeyAndSecond,
                            int durationSeconds,
                            int offsetSeconds)

Method Detail

getDataStream

public DataStream<Row> getDataStream(StreamExecutionEnvironment execEnv)

Specified by:

getDataStream in interface org.apache.flink.table.sources.StreamTableSource<Row>

getReturnType

public TypeInformation<Row> getReturnType()

Specified by:

getReturnType in interface org.apache.flink.table.sources.TableSource<Row>

getTableSchema

public org.apache.flink.table.api.TableSchema getTableSchema()

Specified by:

getTableSchema in interface org.apache.flink.table.sources.TableSource<Row>

explainSource

public String explainSource()

Specified by:

explainSource in interface org.apache.flink.table.sources.TableSource<Row>

getRowtimeAttributeDescriptors

public List<org.apache.flink.table.sources.RowtimeAttributeDescriptor> getRowtimeAttributeDescriptors()

Specified by:

getRowtimeAttributeDescriptors in interface org.apache.flink.table.sources.DefinedRowtimeAttributes

getFieldMapping

public Map<String,String> getFieldMapping()

Specified by:

getFieldMapping in interface org.apache.flink.table.sources.DefinedFieldMapping