Package org.apache.flink.table.api
Class Schema.UnresolvedWatermarkSpec
- java.lang.Object
-
- org.apache.flink.table.api.Schema.UnresolvedWatermarkSpec
-
- Enclosing class:
- Schema
@PublicEvolving public static final class Schema.UnresolvedWatermarkSpec extends Object
Declaration of a watermark strategy that will be resolved toWatermarkSpec
during schema resolution.
-
-
Constructor Summary
Constructors Constructor Description UnresolvedWatermarkSpec(String columnName, Expression watermarkExpression)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(Object o)
String
getColumnName()
Expression
getWatermarkExpression()
int
hashCode()
String
toString()
-
-
-
Constructor Detail
-
UnresolvedWatermarkSpec
public UnresolvedWatermarkSpec(String columnName, Expression watermarkExpression)
-
-
Method Detail
-
getColumnName
public String getColumnName()
-
getWatermarkExpression
public Expression getWatermarkExpression()
-
-