Uses of Class
org.apache.flink.sql.parser.ddl.SqlWatermark

Packages that use SqlWatermark

Package	Description
org.apache.flink.sql.parser	Flink sql parser.
org.apache.flink.sql.parser.ddl

Uses of SqlWatermark in org.apache.flink.sql.parser

Methods in org.apache.flink.sql.parser with parameters of type SqlWatermark

Modifier and Type	Method	Description
static void	SqlUnparseUtils.unparseTableSchema(org.apache.calcite.sql.SqlWriter writer, int leftPrec, int rightPrec, org.apache.calcite.sql.SqlNodeList columnList, List<SqlTableConstraint> constraints, SqlWatermark watermark)

Uses of SqlWatermark in org.apache.flink.sql.parser.ddl

Fields in org.apache.flink.sql.parser.ddl declared as SqlWatermark

Modifier and Type	Field	Description
protected SqlWatermark	SqlAlterTableSchema.watermark
SqlWatermark	SqlCreateTable.TableCreationContext.watermark

Methods in org.apache.flink.sql.parser.ddl that return types with arguments of type SqlWatermark

Modifier and Type	Method	Description
Optional<SqlWatermark>	SqlAlterTableSchema.getWatermark()
Optional<SqlWatermark>	SqlCreateTable.getWatermark()
Optional<SqlWatermark>	SqlReplaceTableAs.getWatermark()

Constructors in org.apache.flink.sql.parser.ddl with parameters of type SqlWatermark

Constructor	Description
SqlAlterTableAdd(org.apache.calcite.sql.parser.SqlParserPos pos, org.apache.calcite.sql.SqlIdentifier tableName, org.apache.calcite.sql.SqlNodeList addedColumns, List<SqlTableConstraint> constraint, SqlWatermark sqlWatermark, boolean ifTableExists)
SqlAlterTableModify(org.apache.calcite.sql.parser.SqlParserPos pos, org.apache.calcite.sql.SqlIdentifier tableName, org.apache.calcite.sql.SqlNodeList modifiedColumns, List<SqlTableConstraint> constraints, SqlWatermark watermark, boolean ifTableExists)
SqlAlterTableSchema(org.apache.calcite.sql.parser.SqlParserPos pos, org.apache.calcite.sql.SqlIdentifier tableName, org.apache.calcite.sql.SqlNodeList columnList, List<SqlTableConstraint> constraints, SqlWatermark sqlWatermark, boolean ifTableExists)
SqlCreateTable(org.apache.calcite.sql.parser.SqlParserPos pos, org.apache.calcite.sql.SqlIdentifier tableName, org.apache.calcite.sql.SqlNodeList columnList, List<SqlTableConstraint> tableConstraints, org.apache.calcite.sql.SqlNodeList propertyList, org.apache.calcite.sql.SqlNodeList partitionKeyList, SqlWatermark watermark, org.apache.calcite.sql.SqlCharStringLiteral comment, boolean isTemporary, boolean ifNotExists)
SqlCreateTable(org.apache.calcite.sql.SqlSpecialOperator operator, org.apache.calcite.sql.parser.SqlParserPos pos, org.apache.calcite.sql.SqlIdentifier tableName, org.apache.calcite.sql.SqlNodeList columnList, List<SqlTableConstraint> tableConstraints, org.apache.calcite.sql.SqlNodeList propertyList, org.apache.calcite.sql.SqlNodeList partitionKeyList, SqlWatermark watermark, org.apache.calcite.sql.SqlCharStringLiteral comment, boolean isTemporary, boolean ifNotExists)
SqlCreateTableAs(org.apache.calcite.sql.parser.SqlParserPos pos, org.apache.calcite.sql.SqlIdentifier tableName, org.apache.calcite.sql.SqlNodeList columnList, List<SqlTableConstraint> tableConstraints, org.apache.calcite.sql.SqlNodeList propertyList, org.apache.calcite.sql.SqlNodeList partitionKeyList, SqlWatermark watermark, org.apache.calcite.sql.SqlCharStringLiteral comment, org.apache.calcite.sql.SqlNode asQuery, boolean isTemporary, boolean ifNotExists)
SqlCreateTableLike(org.apache.calcite.sql.parser.SqlParserPos pos, org.apache.calcite.sql.SqlIdentifier tableName, org.apache.calcite.sql.SqlNodeList columnList, List<SqlTableConstraint> tableConstraints, org.apache.calcite.sql.SqlNodeList propertyList, org.apache.calcite.sql.SqlNodeList partitionKeyList, SqlWatermark watermark, org.apache.calcite.sql.SqlCharStringLiteral comment, SqlTableLike tableLike, boolean isTemporary, boolean ifNotExists)
SqlReplaceTableAs(org.apache.calcite.sql.parser.SqlParserPos pos, org.apache.calcite.sql.SqlIdentifier tableName, org.apache.calcite.sql.SqlNodeList columnList, List<SqlTableConstraint> tableConstraints, org.apache.calcite.sql.SqlNodeList propertyList, org.apache.calcite.sql.SqlNodeList partitionKeyList, SqlWatermark watermark, org.apache.calcite.sql.SqlCharStringLiteral comment, org.apache.calcite.sql.SqlNode asQuery, boolean isTemporary, boolean ifNotExists, boolean isCreateOrReplace)