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 ea4112aefa7 [FLINK-35161][state] Implement StateExecutor for
ForStStateBackend
new 84f0632b15c [FLINK-35195][test/test-filesystem] test-filesystem
Catalog support create generic table
new b037f56b10c [FLINK-35195][table] Introduce materialized table reflated
config options
new d8491c0f9c0 [FLINK-35195][table] Convert CatalogMaterializedTable to
CatalogTable to generate execution plan for planner
new e28e495cdd3 [FLINK-35195][table] Convert SqlCreateMaterializedTable
node to CreateMaterializedTableOperation
new c99eb54ce8f [FLINK-35195][table] Introduce ContinuousRefreshHandler
and serializer for continuous refresh mode
new 192e1e8fb04 [FLINK-35195][table] Introduce MaterializedTableChange to
support update materialized table refresh status and RefreshHandler
new e0d342a2a6b [FLINK-35195][table] Introduce
DropMaterializedTableOperation to support drop materialized table
new 29736b8c019 [FLINK-35195][table] Support execute
CreateMaterializedTableOperation for continuous refresh mode in SqlGateway
The 8 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:
docs/content.zh/docs/dev/table/config.md | 6 +
docs/content/docs/dev/table/config.md | 6 +
.../materialized_table_config_configuration.html | 24 ++
flink-table/flink-sql-gateway/pom.xml | 6 +
.../MaterializedTableManager.java | 182 ++++++++++++++
.../service/operation/OperationExecutor.java | 25 +-
.../service/MaterializedTableStatementITCase.java | 274 +++++++++++++++++++++
.../flink/sql/parser/SqlConstraintValidator.java | 2 +-
.../sql/parser/ddl/SqlCreateMaterializedTable.java | 1 -
.../api/config/MaterializedTableConfigOptions.java | 59 +++++
.../apache/flink/table/catalog/CatalogManager.java | 3 +-
.../flink/table/catalog/ContextResolvedTable.java | 26 ++
.../operations/ddl/AlterTableChangeOperation.java | 6 +-
.../AlterMaterializedTableChangeOperation.java | 107 ++++++++
.../AlterMaterializedTableOperation.java | 42 ++++
.../CreateMaterializedTableOperation.java | 76 ++++++
.../DropMaterializedTableOperation.java | 54 ++++
.../MaterializedTableOperation.java | 26 ++
.../catalog/ResolvedCatalogMaterializedTable.java | 13 +
.../apache/flink/table/catalog/TableChange.java | 120 +++++++++
.../table/refresh/ContinuousRefreshHandler.java | 50 ++++
.../ContinuousRefreshHandlerSerializer.java | 44 ++++
.../planner/catalog/DatabaseCalciteSchema.java | 3 +-
.../planner/operations/SqlNodeConvertContext.java | 8 +
.../operations/SqlNodeToOperationConversion.java | 4 +-
.../SqlCreateMaterializedTableConverter.java | 210 ++++++++++++++++
.../operations/converters/SqlNodeConverter.java | 5 +
.../operations/converters/SqlNodeConverters.java | 1 +
.../planner/utils/MaterializedTableUtils.java | 98 ++++++++
...erializedTableNodeToOperationConverterTest.java | 259 +++++++++++++++++++
.../SqlNodeToOperationConversionTestBase.java | 2 +-
.../SqlRTASNodeToOperationConverterTest.java | 2 +-
.../file/testutils/TestFileSystemTableFactory.java | 35 ++-
.../testutils/catalog/TestFileSystemCatalog.java | 26 +-
.../catalog/TestFileSystemCatalogITCase.java | 79 +++++-
.../catalog/TestFileSystemCatalogTest.java | 38 +++
36 files changed, 1901 insertions(+), 21 deletions(-)
create mode 100644
docs/layouts/shortcodes/generated/materialized_table_config_configuration.html
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/materializedtable/MaterializedTableManager.java
create mode 100644
flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/MaterializedTableStatementITCase.java
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/MaterializedTableConfigOptions.java
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/materializedtable/AlterMaterializedTableChangeOperation.java
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/materializedtable/AlterMaterializedTableOperation.java
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/materializedtable/CreateMaterializedTableOperation.java
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/materializedtable/DropMaterializedTableOperation.java
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/materializedtable/MaterializedTableOperation.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/refresh/ContinuousRefreshHandler.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/refresh/ContinuousRefreshHandlerSerializer.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/SqlCreateMaterializedTableConverter.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/MaterializedTableUtils.java
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlMaterializedTableNodeToOperationConverterTest.java
