This is an automated email from the ASF dual-hosted git repository.
snuyanzin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 05dee4a2e85 [hotfix][examples] Add Python examples on how to read
binary data from Kafka
new f8e29badfe6 [FLINK-38674][table] Support schema definition for
Materialized tables while `CREATE` operation
new 29cc69d3308 [hotfix][table] Simplify parsing of `REFRESH MODE` for
`MATERIALIZED TABLE`
The 2 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:
.../dev/table/materialized-table/statements.md | 48 +++-
.../dev/table/materialized-table/statements.md | 46 +++-
.../src/main/codegen/includes/parserImpls.ftl | 26 +-
.../sql/parser/ddl/SqlCreateMaterializedTable.java | 78 ++++--
.../MaterializedTableStatementParserTest.java | 143 ++++++++++-
.../AbstractCreateMaterializedTableConverter.java | 216 ++++++++++++++++
.../SqlCreateMaterializedTableConverter.java | 267 ++++++--------------
.../table/AbstractCreateTableConverter.java | 2 +-
.../converters/table/MergeTableAsUtil.java | 2 +-
.../planner/utils/MaterializedTableUtils.java | 28 ++-
.../operations/SqlCTASNodeToOperationTest.java | 26 +-
.../operations/SqlDdlToOperationConverterTest.java | 8 +-
.../operations/SqlDmlToOperationConverterTest.java | 50 ++--
...erializedTableNodeToOperationConverterTest.java | 277 +++++++++++++++++----
.../operations/SqlModelOperationConverterTest.java | 10 +-
.../operations/SqlNodeToCallOperationTest.java | 4 +-
.../SqlNodeToOperationConversionTestBase.java | 6 +-
.../SqlRTASNodeToOperationConverterTest.java | 30 +--
.../SqlShowToOperationConverterTest.java | 6 +-
19 files changed, 897 insertions(+), 376 deletions(-)
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/AbstractCreateMaterializedTableConverter.java
