org.apache.flink.walkthrough.common.table

Class UnboundedTransactionTableSource

java.lang.Object

org.apache.flink.walkthrough.common.table.UnboundedTransactionTableSource

All Implemented Interfaces:

DefinedRowtimeAttributes, StreamTableSource<Row>, TableSource<Row>

@PublicEvolving
public class UnboundedTransactionTableSource
extends Object
implements StreamTableSource<Row>, DefinedRowtimeAttributes

A table source for reading an unbounded set of transactions.

This table could be backed by a message queue or other streaming data source.

Constructor Summary

Constructors

Constructor and Description
UnboundedTransactionTableSource()

Method Summary

Modifier and Type	Method and Description
DataStream<Row>	getDataStream(StreamExecutionEnvironment execEnv) Returns the data of the table as a DataStream.
DataType	getProducedDataType() Returns the DataType for the produced data of the TableSource.
List<RowtimeAttributeDescriptor>	getRowtimeAttributeDescriptors() Returns a list of RowtimeAttributeDescriptor for all rowtime attributes of the table.
TableSchema	getTableSchema() Returns the schema of the produced table.

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

isBounded

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

explainSource, getReturnType

Constructor Detail

UnboundedTransactionTableSource

public UnboundedTransactionTableSource()

Method Detail

getDataStream

public DataStream<Row> getDataStream(StreamExecutionEnvironment execEnv)

Description copied from interface: StreamTableSource

Returns the data of the table as a DataStream.

NOTE: This method is for internal use only for defining a TableSource. Do not use it in Table API programs.

Specified by:

getDataStream in interface StreamTableSource<Row>

getProducedDataType

public DataType getProducedDataType()

Description copied from interface: TableSource

Returns the DataType for the produced data of the TableSource.

Specified by:

getProducedDataType in interface TableSource<Row>

Returns:

The data type of the returned DataSet or DataStream.

getTableSchema

public TableSchema getTableSchema()

Description copied from interface: TableSource

Returns the schema of the produced table.

Specified by:

getTableSchema in interface TableSource<Row>

Returns:

The TableSchema of the produced table.

getRowtimeAttributeDescriptors

public List<RowtimeAttributeDescriptor> getRowtimeAttributeDescriptors()

Description copied from interface: DefinedRowtimeAttributes

Returns a list of RowtimeAttributeDescriptor for all rowtime attributes of the table.

All referenced attributes must be present in the TableSchema of the TableSource and of type Types.SQL_TIMESTAMP.

Specified by:

getRowtimeAttributeDescriptors in interface DefinedRowtimeAttributes

Returns:

A list of RowtimeAttributeDescriptor.