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
org.apache.flink.sql.parser.ddl.materializedtable
org.apache.flink.sql.parser.ddl.table

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.SqlNodeList columnList, List<SqlTableConstraint> constraints, SqlWatermark watermark, org.apache.calcite.sql.SqlWriter writer, int leftPrec, int rightPrec)

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
SqlWatermark	TableSchemaContext.watermark

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

Constructor

Description

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, SqlDistribution distribution, 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)

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

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

Modifier and Type	Field	Description
protected SqlWatermark	SqlAlterMaterializedTableSchema.watermark

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

Modifier and Type	Method	Description
Optional<SqlWatermark>	SqlAlterMaterializedTableSchema.getWatermark()
Optional<SqlWatermark>	SqlCreateMaterializedTable.getWatermark()

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

Constructor	Description
SqlAlterMaterializedTableAddSchema(org.apache.calcite.sql.parser.SqlParserPos pos, org.apache.calcite.sql.SqlIdentifier materializedTableName, org.apache.calcite.sql.SqlNodeList columnList, List<SqlTableConstraint> constraints, SqlWatermark sqlWatermark)
SqlAlterMaterializedTableModifySchema(org.apache.calcite.sql.parser.SqlParserPos pos, org.apache.calcite.sql.SqlIdentifier materializedTableName, org.apache.calcite.sql.SqlNodeList columnList, List<SqlTableConstraint> constraints, SqlWatermark sqlWatermark)
SqlAlterMaterializedTableSchema(org.apache.calcite.sql.parser.SqlParserPos pos, org.apache.calcite.sql.SqlIdentifier materializedTableName, org.apache.calcite.sql.SqlNodeList columnList, List<SqlTableConstraint> constraints, SqlWatermark sqlWatermark)
SqlCreateMaterializedTable(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, SqlWatermark watermark, org.apache.calcite.sql.SqlCharStringLiteral comment, SqlDistribution distribution, org.apache.calcite.sql.SqlNodeList partitionKeyList, org.apache.calcite.sql.SqlNodeList propertyList, org.apache.calcite.sql.SqlIntervalLiteral freshness, SqlRefreshMode refreshMode, SqlStartMode startMode, org.apache.calcite.sql.SqlNode asQuery)
SqlCreateOrAlterMaterializedTable(org.apache.calcite.sql.parser.SqlParserPos pos, org.apache.calcite.sql.SqlIdentifier tableName, org.apache.calcite.sql.SqlNodeList columnList, List<SqlTableConstraint> tableConstraints, SqlWatermark watermark, org.apache.calcite.sql.SqlCharStringLiteral comment, SqlDistribution distribution, org.apache.calcite.sql.SqlNodeList partitionKeyList, org.apache.calcite.sql.SqlNodeList propertyList, org.apache.calcite.sql.SqlIntervalLiteral freshness, SqlRefreshMode refreshMode, SqlStartMode startMode, org.apache.calcite.sql.SqlNode asQuery, boolean isOrAlter)

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

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

Modifier and Type	Field	Description
protected SqlWatermark	SqlAlterTableSchema.watermark

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

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

Constructors in org.apache.flink.sql.parser.ddl.table 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)
SqlAlterTableDrop(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)
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, SqlDistribution distribution, 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, SqlDistribution distribution, org.apache.calcite.sql.SqlNodeList partitionKeyList, SqlWatermark watermark, org.apache.calcite.sql.SqlCharStringLiteral comment, boolean isTemporary, boolean ifNotExists, boolean replace)
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, SqlDistribution distribution, 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, SqlDistribution distribution, org.apache.calcite.sql.SqlNodeList partitionKeyList, SqlWatermark watermark, org.apache.calcite.sql.SqlCharStringLiteral comment, SqlTableLike tableLike, boolean isTemporary, boolean ifNotExists)