org.apache.flink.table.sources

Class RowtimeAttributeDescriptor

java.lang.Object

org.apache.flink.table.sources.RowtimeAttributeDescriptor

public final class RowtimeAttributeDescriptor
extends Object

Describes a rowtime attribute of a TableSource.

Constructor Summary

Constructors

Constructor and Description
RowtimeAttributeDescriptor(String attributeName, TimestampExtractor timestampExtractor, WatermarkStrategy watermarkStrategy)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
String	getAttributeName() Returns the name of the rowtime attribute.
TimestampExtractor	getTimestampExtractor() Returns the [[TimestampExtractor]] for the attribute.
WatermarkStrategy	getWatermarkStrategy() Returns the [[WatermarkStrategy]] for the attribute.
int	hashCode()

Methods inherited from class java.lang.Object

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

Constructor Detail

RowtimeAttributeDescriptor

public RowtimeAttributeDescriptor(String attributeName,
                                  TimestampExtractor timestampExtractor,
                                  WatermarkStrategy watermarkStrategy)

Method Detail

getAttributeName

public String getAttributeName()

Returns the name of the rowtime attribute.

getTimestampExtractor

public TimestampExtractor getTimestampExtractor()

Returns the [[TimestampExtractor]] for the attribute.

getWatermarkStrategy

public WatermarkStrategy getWatermarkStrategy()

Returns the [[WatermarkStrategy]] for the attribute.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object