This is an automated email from the ASF dual-hosted git repository.
gustavodemorais pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 692507671e8 [FLINK-39425][metrics] `OpenTelemetryEventReporter`
ignores `service.name` and `service.version config`
new bca2c0a6170 [FLINK-39636][table] Add produces_full_deletes parameter
to TO_CHANGELOG
new 340fbf879fd [FLINK-39636][table] Refactor ToChangelogTypeStrategy
new d763453e045 [FLINK-39735][table] Expose input upsert key on
TableSemantics
new 32f9e60eb9d [FLINK-39636][table] Emit partial DELETE rows in
TO_CHANGELOG via upsert key
new e400c2c2213 [FLINK-39636][table] Remove unnecessary validation in
TO_CHANGELOG
new c033b17fae2 [FLINK-39636][table] Widen output column nullability for
partial deletes
The 6 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/sql/reference/queries/changelog.md | 115 +++++++++++--
flink-python/pyflink/table/table.py | 19 ++-
.../apache/flink/table/api/PartitionedTable.java | 10 +-
.../java/org/apache/flink/table/api/Table.java | 10 +-
.../resolver/rules/ResolveCallByArgumentsRule.java | 5 +
.../functions/BuiltInFunctionDefinitions.java | 46 +++--
.../flink/table/functions/TableSemantics.java | 33 ++++
.../table/types/inference/BuiltInCondition.java | 1 +
.../table/types/inference/TraitCondition.java | 11 ++
.../strategies/ChangelogTypeStrategyUtils.java | 24 +++
.../strategies/ToChangelogTypeStrategy.java | 182 +++++++++++++-------
.../apache/flink/table/utils/UpsertKeyUtils.java | 67 ++++++++
.../ToChangelogInputTypeStrategyTest.java | 133 +++++++++++++++
.../ToChangelogOutputTypeStrategyTest.java | 110 ++++++++++++
.../types/inference/utils/TableSemanticsMock.java | 25 +++
.../functions/bridging/BridgingSqlFunction.java | 19 ++-
.../inference/CallBindingCallContext.java | 6 +
.../inference/OperatorBindingCallContext.java | 48 +++++-
.../stream/StreamExecProcessTableFunction.java | 38 +++--
.../stream/StreamPhysicalProcessTableFunction.java | 19 ++-
.../table/planner/plan/utils/UpsertKeyUtil.java | 23 +--
.../codegen/ProcessTableRunnerGenerator.scala | 10 +-
.../exec/stream/ToChangelogSemanticTests.java | 9 +-
.../nodes/exec/stream/ToChangelogTestPrograms.java | 190 +++++++++++++++++++--
.../planner/plan/stream/sql/ToChangelogTest.java | 38 +++++
.../planner/plan/stream/sql/ToChangelogTest.xml | 66 +++++--
.../plan/to-changelog-retract-restore.json | 10 +-
.../runtime/functions/ptf/ToChangelogFunction.java | 132 ++++++++++----
.../operators/process/RuntimeTableSemantics.java | 11 +-
...essSetTableOperatorInterruptibleTimersTest.java | 3 +-
.../functions/TestHarnessTableSemantics.java | 14 ++
31 files changed, 1235 insertions(+), 192 deletions(-)
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/UpsertKeyUtils.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/strategies/ToChangelogInputTypeStrategyTest.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/strategies/ToChangelogOutputTypeStrategyTest.java
