This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 2c260b5 [FLINK-22881] Revert toggling IDLE/ACTIVE on records in IDLE
state
add 5957812 [FLINK-22901][table] Introduce getUpsertKeys in
FlinkRelMetadataQuery
No new revisions were added by this update.
Summary of changes:
.../table/planner/plan/metadata/FlinkMetadata.java | 16 +
.../plan/metadata/FlinkRelMetadataQuery.java | 52 +++
.../metadata/FlinkDefaultRelMetadataProvider.scala | 1 +
.../plan/metadata/FlinkRelMdUniqueKeys.scala | 85 ++---
.../plan/metadata/FlinkRelMdUpsertKeys.scala | 301 +++++++++++++++++
.../stream/StreamPhysicalOverAggregate.scala | 2 +-
.../StreamCommonSubGraphBasedOptimizer.scala | 1 +
.../planner/plan/schema/IntermediateRelTable.scala | 7 +-
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 128 +++++--
.../plan/metadata/FlinkRelMdUpsertKeysTest.scala | 372 +++++++++++++++++++++
10 files changed, 893 insertions(+), 72 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdUpsertKeys.scala
create mode 100644
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdUpsertKeysTest.scala
