This is an automated email from the ASF dual-hosted git repository.
ron pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 329ad1e22b6 [FLINK-37029][docs] Fix the materialized table docs of
full mode cron expression (#25917)
new 342e3bf1272 [FLINK-36994][table] Support parsing ALTER MATERIALIZED
TABLE AS statement
new 9260b33cc51 [FLINK-36994][table] Support converting ALTER MATERIALIZED
TABLE AS node to operation
new 44208050673 [FLINK-36994][table] Support executing ALTER MATERIALIZED
TABLE AS operation
new 5e0e5a233eb [FLINK-36994][table] Fix expand sql error when
materialized table creation with UDTF queries
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../MaterializedTableManager.java | 173 +++++++++-
.../service/MaterializedTableStatementITCase.java | 349 +++++++++++++++++++++
.../src/main/codegen/data/Parser.tdd | 1 +
.../src/main/codegen/includes/parserImpls.ftl | 10 +
....java => SqlAlterMaterializedTableAsQuery.java} | 21 +-
.../MaterializedTableStatementParserTest.java | 22 ++
...=> AlterMaterializedTableAsQueryOperation.java} | 32 +-
.../AlterMaterializedTableChangeOperation.java | 28 +-
.../apache/flink/table/catalog/TableChange.java | 93 +++++-
.../SqlAlterMaterializedTableAsQueryConverter.java | 161 ++++++++++
.../SqlCreateMaterializedTableConverter.java | 14 +-
.../operations/converters/SqlNodeConverters.java | 1 +
...erializedTableNodeToOperationConverterTest.java | 185 ++++++++++-
13 files changed, 1038 insertions(+), 52 deletions(-)
copy
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/{SqlAlterMaterializedTableSuspend.java
=> SqlAlterMaterializedTableAsQuery.java} (70%)
copy
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/materializedtable/{AlterMaterializedTableSuspendOperation.java
=> AlterMaterializedTableAsQueryOperation.java} (52%)
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/SqlAlterMaterializedTableAsQueryConverter.java
