org.apache.flink.table.api

Class WatermarkSpec

java.lang.Object

org.apache.flink.table.api.WatermarkSpec

public class WatermarkSpec
extends Object

Watermark metadata defined in TableSchema. It mainly contains 3 parts:

1. the rowtime attribute.
2. the string representation of watermark generation expression.
3. the data type of the computation result of watermark generation expression.

Constructor Summary

Constructors

Constructor and Description
WatermarkSpec(String rowtimeAttribute, String watermarkExpressionString, DataType watermarkExprOutputType)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
String	getRowtimeAttribute() Returns the name of rowtime attribute, it can be a nested field using dot separator.
String	getWatermarkExpr() Returns the string representation of watermark generation expression.
DataType	getWatermarkExprOutputType() Returns the data type of the computation result of watermark generation expression.
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

WatermarkSpec

public WatermarkSpec(String rowtimeAttribute,
                     String watermarkExpressionString,
                     DataType watermarkExprOutputType)

Method Detail

getRowtimeAttribute

public String getRowtimeAttribute()

Returns the name of rowtime attribute, it can be a nested field using dot separator. The referenced attribute must be present in the TableSchema and of type LogicalTypeRoot.TIMESTAMP_WITHOUT_TIME_ZONE.

getWatermarkExpr

public String getWatermarkExpr()

Returns the string representation of watermark generation expression. The string representation is a qualified SQL expression string (UDFs are expanded).

getWatermarkExprOutputType

public DataType getWatermarkExprOutputType()

Returns the data type of the computation result of watermark generation expression.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object