| Package | Description |
|---|---|
| org.apache.flink.table.planner.operations | |
| org.apache.flink.table.planner.operations.converters |
| Modifier and Type | Class and Description |
|---|---|
class |
SqlNodeConvertContext
An implementation of
SqlNodeConverter.ConvertContext. |
| Modifier and Type | Method and Description |
|---|---|
org.apache.flink.table.operations.Operation |
SqlAlterTableAddPartitionConverter.convertSqlNode(org.apache.flink.sql.parser.ddl.SqlAddPartitions sqlAddPartitions,
SqlNodeConverter.ConvertContext context) |
org.apache.flink.table.operations.Operation |
SqlAlterCatalogCommentConverter.convertSqlNode(org.apache.flink.sql.parser.ddl.SqlAlterCatalogComment sqlAlterCatalogComment,
SqlNodeConverter.ConvertContext context) |
org.apache.flink.table.operations.Operation |
SqlAlterCatalogOptionsConverter.convertSqlNode(org.apache.flink.sql.parser.ddl.SqlAlterCatalogOptions sqlAlterCatalogOptions,
SqlNodeConverter.ConvertContext context) |
org.apache.flink.table.operations.Operation |
SqlAlterCatalogResetConverter.convertSqlNode(org.apache.flink.sql.parser.ddl.SqlAlterCatalogReset sqlAlterCatalogReset,
SqlNodeConverter.ConvertContext context) |
org.apache.flink.table.operations.Operation |
SqlAlterMaterializedTableRefreshConverter.convertSqlNode(org.apache.flink.sql.parser.ddl.SqlAlterMaterializedTableRefresh node,
SqlNodeConverter.ConvertContext context) |
org.apache.flink.table.operations.Operation |
SqlAlterMaterializedTableResumeConverter.convertSqlNode(org.apache.flink.sql.parser.ddl.SqlAlterMaterializedTableResume sqlAlterMaterializedTableResume,
SqlNodeConverter.ConvertContext context) |
org.apache.flink.table.operations.Operation |
SqlAlterMaterializedTableSuspendConverter.convertSqlNode(org.apache.flink.sql.parser.ddl.SqlAlterMaterializedTableSuspend node,
SqlNodeConverter.ConvertContext context) |
org.apache.flink.table.operations.Operation |
SqlAlterViewAsConverter.convertSqlNode(org.apache.flink.sql.parser.ddl.SqlAlterViewAs alterView,
SqlNodeConverter.ConvertContext context) |
org.apache.flink.table.operations.Operation |
SqlAlterViewPropertiesConverter.convertSqlNode(org.apache.flink.sql.parser.ddl.SqlAlterViewProperties alterView,
SqlNodeConverter.ConvertContext context) |
org.apache.flink.table.operations.Operation |
SqlAlterViewRenameConverter.convertSqlNode(org.apache.flink.sql.parser.ddl.SqlAlterViewRename alterView,
SqlNodeConverter.ConvertContext context) |
org.apache.flink.table.operations.Operation |
SqlCreateCatalogConverter.convertSqlNode(org.apache.flink.sql.parser.ddl.SqlCreateCatalog node,
SqlNodeConverter.ConvertContext context) |
org.apache.flink.table.operations.Operation |
SqlCreateMaterializedTableConverter.convertSqlNode(org.apache.flink.sql.parser.ddl.SqlCreateMaterializedTable sqlCreateMaterializedTable,
SqlNodeConverter.ConvertContext context) |
org.apache.flink.table.operations.Operation |
SqlCreateViewConverter.convertSqlNode(org.apache.flink.sql.parser.ddl.SqlCreateView sqlCreateView,
SqlNodeConverter.ConvertContext context) |
org.apache.flink.table.operations.Operation |
SqlDescribeCatalogConverter.convertSqlNode(org.apache.flink.sql.parser.dql.SqlDescribeCatalog sqlDescribeCatalog,
SqlNodeConverter.ConvertContext context) |
org.apache.flink.table.operations.Operation |
SqlDescribeJobConverter.convertSqlNode(org.apache.flink.sql.parser.dql.SqlDescribeJob node,
SqlNodeConverter.ConvertContext context) |
org.apache.flink.table.operations.Operation |
SqlDropMaterializedTableConverter.convertSqlNode(org.apache.flink.sql.parser.ddl.SqlDropMaterializedTable sqlDropMaterializedTable,
SqlNodeConverter.ConvertContext context) |
org.apache.flink.table.operations.Operation |
SqlAlterTableDropPartitionConverter.convertSqlNode(org.apache.flink.sql.parser.ddl.SqlDropPartitions sqlDropPartitions,
SqlNodeConverter.ConvertContext context) |
org.apache.flink.table.operations.Operation |
SqlProcedureCallConverter.convertSqlNode(org.apache.calcite.sql.SqlNode sqlNode,
SqlNodeConverter.ConvertContext context) |
org.apache.flink.table.operations.Operation |
SqlQueryConverter.convertSqlNode(org.apache.calcite.sql.SqlNode node,
SqlNodeConverter.ConvertContext context) |
static Optional<org.apache.flink.table.operations.Operation> |
SqlNodeConverters.convertSqlNode(org.apache.calcite.sql.SqlNode validatedSqlNode,
SqlNodeConverter.ConvertContext context)
Convert the given validated SqlNode into Operation if there is a registered converter for the
node.
|
org.apache.flink.table.operations.Operation |
SqlReplaceTableAsConverter.convertSqlNode(org.apache.flink.sql.parser.ddl.SqlReplaceTableAs sqlReplaceTableAs,
SqlNodeConverter.ConvertContext context) |
org.apache.flink.table.operations.Operation |
SqlShowCreateCatalogConverter.convertSqlNode(org.apache.flink.sql.parser.dql.SqlShowCreateCatalog sqlShowCreateCatalog,
SqlNodeConverter.ConvertContext context) |
org.apache.flink.table.operations.Operation |
SqlShowDatabasesConverter.convertSqlNode(org.apache.flink.sql.parser.dql.SqlShowDatabases sqlShowDatabases,
SqlNodeConverter.ConvertContext context) |
org.apache.flink.table.operations.Operation |
SqlShowFunctionsConverter.convertSqlNode(org.apache.flink.sql.parser.dql.SqlShowFunctions sqlShowFunctions,
SqlNodeConverter.ConvertContext context) |
org.apache.flink.table.operations.Operation |
SqlShowPartitionsConverter.convertSqlNode(org.apache.flink.sql.parser.dql.SqlShowPartitions sqlShowPartitions,
SqlNodeConverter.ConvertContext context) |
org.apache.flink.table.operations.Operation |
SqlShowProcedureConverter.convertSqlNode(org.apache.flink.sql.parser.dql.SqlShowProcedures sqlShowProcedures,
SqlNodeConverter.ConvertContext context) |
org.apache.flink.table.operations.Operation |
SqlTruncateTableConverter.convertSqlNode(org.apache.flink.sql.parser.dml.SqlTruncateTable sqlTruncateTable,
SqlNodeConverter.ConvertContext context) |
org.apache.flink.table.operations.Operation |
SqlNodeConverter.convertSqlNode(S node,
SqlNodeConverter.ConvertContext context)
Convert the given validated
SqlNode into an Operation. |
Copyright © 2014–2025 The Apache Software Foundation. All rights reserved.