public class SqlWatermark
extends org.apache.calcite.sql.SqlCall
WATERMARK FOR ts AS ts - INTERVAL '5'
SECOND
.Constructor and Description |
---|
SqlWatermark(org.apache.calcite.sql.parser.SqlParserPos pos,
org.apache.calcite.sql.SqlIdentifier eventTimeColumnName,
org.apache.calcite.sql.SqlNode watermarkStrategy) |
Modifier and Type | Method and Description |
---|---|
org.apache.calcite.sql.SqlIdentifier |
getEventTimeColumnName() |
List<org.apache.calcite.sql.SqlNode> |
getOperandList() |
org.apache.calcite.sql.SqlOperator |
getOperator() |
org.apache.calcite.sql.SqlNode |
getWatermarkStrategy() |
void |
unparse(org.apache.calcite.sql.SqlWriter writer,
int leftPrec,
int rightPrec) |
accept, clone, equalsDeep, findValidOptions, getCallSignature, getFunctionQuantifier, getKind, getMonotonicity, isCountStar, isExpanded, operand, operandCount, setOperand, validate
public SqlWatermark(org.apache.calcite.sql.parser.SqlParserPos pos, org.apache.calcite.sql.SqlIdentifier eventTimeColumnName, org.apache.calcite.sql.SqlNode watermarkStrategy)
public org.apache.calcite.sql.SqlOperator getOperator()
getOperator
in class org.apache.calcite.sql.SqlCall
public List<org.apache.calcite.sql.SqlNode> getOperandList()
getOperandList
in class org.apache.calcite.sql.SqlCall
public void unparse(org.apache.calcite.sql.SqlWriter writer, int leftPrec, int rightPrec)
unparse
in class org.apache.calcite.sql.SqlCall
public org.apache.calcite.sql.SqlIdentifier getEventTimeColumnName()
public org.apache.calcite.sql.SqlNode getWatermarkStrategy()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.