org.apache.flink.table.sources

Interface DefinedRowtimeAttributes

All Known Implementing Classes:

StreamSQLTestProgram.GeneratorTableSource

Deprecated.

This interface will not be supported in the new source design around DynamicTableSource. Use the concept of computed columns instead. See FLIP-95 for more information.

@Deprecated
 @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() Deprecated. Returns a list of RowtimeAttributeDescriptor for all rowtime attributes of the table.

Method Detail

getRowtimeAttributeDescriptors

List<RowtimeAttributeDescriptor> getRowtimeAttributeDescriptors()

Deprecated.

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.