This is an automated email from the ASF dual-hosted git repository.
yuxia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 41b35260bba [FLINK-32493][table-runtime] Introduce
GlobalRuntimeFilterBuilderOperator
add 410b52a35a1 [FLINK-32474][table] Support time travel in table planner
(#22939)
No new revisions were added by this update.
Summary of changes:
.../apache/flink/table/catalog/CatalogManager.java | 39 ++-
.../sql/validate/IdentifierSnapshotNamespace.java} | 29 +-
.../apache/calcite/sql/validate/SnapshotScope.java | 62 ++++
.../sql/validate/SqlValidatorWithSnapshot.java} | 27 +-
.../apache/calcite/sql2rel/SqlToRelConverter.java | 71 ++++-
.../planner/calcite/FlinkCalciteSqlValidator.java | 153 +++++++++-
.../planner/calcite/TimestampSchemaVersion.java | 51 ++++
.../planner/catalog/CatalogCalciteSchema.java | 15 +-
.../catalog/CatalogManagerCalciteSchema.java | 12 +-
.../planner/catalog/DatabaseCalciteSchema.java | 28 +-
.../flink/table/planner/catalog/FlinkSchema.java | 15 +-
.../plan/FlinkCalciteCatalogSnapshotReader.java} | 29 +-
.../table/planner/calcite/FlinkPlannerImpl.scala | 5 +-
.../plan/nodes/logical/FlinkLogicalSnapshot.scala | 11 +-
.../planner/factories/TestTimeTravelCatalog.java | 94 ++++++
.../runtime/batch/sql/TimeTravelITCase.java | 324 +++++++++++++++++++++
.../plan/batch/sql/join/LookupJoinTest.scala | 10 -
.../plan/stream/sql/join/LookupJoinTest.scala | 21 --
.../plan/stream/sql/join/TemporalJoinTest.scala | 18 --
19 files changed, 896 insertions(+), 118 deletions(-)
copy
flink-table/{flink-table-code-splitter/src/main/java/org/apache/flink/table/codesplit/ReturnAndJumpCounter.java
=>
flink-table-planner/src/main/java/org/apache/calcite/sql/validate/IdentifierSnapshotNamespace.java}
(56%)
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql/validate/SnapshotScope.java
copy
flink-table/{flink-table-code-splitter/src/main/java/org/apache/flink/table/codesplit/ReturnAndJumpCounter.java
=>
flink-table-planner/src/main/java/org/apache/calcite/sql/validate/SqlValidatorWithSnapshot.java}
(53%)
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/TimestampSchemaVersion.java
copy
flink-table/{flink-sql-parser/src/main/java/org/apache/flink/table/calcite/ExtendedRelTypeFactory.java
=>
flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/FlinkCalciteCatalogSnapshotReader.java}
(52%)
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/factories/TestTimeTravelCatalog.java
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/batch/sql/TimeTravelITCase.java
