org.apache.flink.table.sources

Interface DefinedProctimeAttribute

All Known Implementing Classes:

Kafka010TableSource, Kafka011TableSource, Kafka08TableSource, Kafka09TableSource, KafkaTableSource, KafkaTableSourceBase

@PublicEvolving
public interface DefinedProctimeAttribute

Extends a TableSource to specify a processing time attribute.

Method Summary

Modifier and Type	Method and Description
String	getProctimeAttribute() Returns the name of a processing time attribute or null if no processing time attribute is present.

Method Detail

getProctimeAttribute

@Nullable
String getProctimeAttribute()

Returns the name of a processing time attribute or null if no processing time attribute is present.

The referenced attribute must be present in the TableSchema of the TableSource and of type Types.SQL_TIMESTAMP.