This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 89d9f14c982 [FLINK-37760][format] Bump parquet from 1.15.1 to 1.15.2
add ddd65bd0374 [FLINK-37632][table] Add changelog support to PTFs
No new revisions were added by this update.
Summary of changes:
docs/content.zh/docs/dev/table/functions/ptfs.md | 358 ++++++++++++++++++++-
docs/content/docs/dev/table/functions/ptfs.md | 358 ++++++++++++++++++++-
.../flink/table/annotation/ArgumentTrait.java | 101 +++++-
.../flink/table/functions/ChangelogFunction.java | 110 +++++++
.../table/functions/ProcessTableFunction.java | 12 +
.../flink/table/types/inference/CallContext.java | 21 +-
.../table/types/inference/StaticArgument.java | 9 +-
.../table/types/inference/StaticArgumentTrait.java | 6 +-
.../inference/OperatorBindingCallContext.java | 12 +-
.../stream/StreamExecProcessTableFunction.java | 65 ++--
.../stream/StreamPhysicalProcessTableFunction.java | 187 ++++++++++-
.../table/planner/plan/trait/ModifyKindSet.java | 22 +-
.../flink/table/planner/utils/ShortcutUtils.java | 9 +
.../codegen/ProcessTableRunnerGenerator.scala | 64 +---
.../plan/metadata/FlinkRelMdUniqueKeys.scala | 29 +-
.../plan/metadata/FlinkRelMdUpsertKeys.scala | 8 +-
.../FlinkChangelogModeInferenceProgram.scala | 286 ++++++++++++++--
.../planner/plan/utils/ChangelogPlanUtils.scala | 51 +--
.../stream/ProcessTableFunctionSemanticTests.java | 12 +-
.../stream/ProcessTableFunctionTestPrograms.java | 258 +++++++++++++--
.../exec/stream/ProcessTableFunctionTestUtils.java | 230 +++++++++----
.../plan/stream/sql/ProcessTableFunctionTest.java | 104 ++++--
.../operators/process/PassAllCollector.java | 5 +-
.../process/PassPartitionKeysCollector.java | 8 +-
.../process/PassThroughCollectorBase.java | 18 +-
.../operators/process/ProcessTableOperator.java | 25 +-
.../process/ProcessTableOperatorFactory.java | 13 +-
.../process/ReadableInternalTimeContext.java | 4 +-
.../operators/process/RuntimeChangelogMode.java | 55 ++++
.../operators/process/RuntimeTableSemantics.java | 13 +-
30 files changed, 2139 insertions(+), 314 deletions(-)
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/ChangelogFunction.java
create mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/process/RuntimeChangelogMode.java
