org.apache.flink.table.sources

Interface DefinedRowtimeAttributes

All Known Implementing Classes:

Kafka010TableSource, Kafka011TableSource, KafkaTableSource, KafkaTableSourceBase, StreamSQLTestProgram.GeneratorTableSource

@PublicEvolving
public interface DefinedRowtimeAttributes

Extends a TableSource to specify rowtime attributes via a RowtimeAttributeDescriptor.

Method Summary

Modifier and Type	Method and Description
List<RowtimeAttributeDescriptor>	getRowtimeAttributeDescriptors() Returns a list of RowtimeAttributeDescriptor for all rowtime attributes of the table.

Method Detail

getRowtimeAttributeDescriptors

List<RowtimeAttributeDescriptor> getRowtimeAttributeDescriptors()

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.

Returns:

A list of RowtimeAttributeDescriptor.