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 3aa267b [FLINK-26076] Fix ArchUnit violations in
Source(Sink)MetricsITCase
add 3adca15 [FLINK-25990][table-api-java-bridge] Add ProviderContext for
generating uids in DataStream/Transformation Scan/SinkProvider
No new revisions were added by this update.
Summary of changes:
.../connector/file/table/FileSystemTableSink.java | 17 ++++++--
.../connector/file/table/stream/StreamingSink.java | 14 ++++++-
.../flink/connectors/hive/HiveTableSink.java | 29 +++++++++++--
.../flink/connectors/hive/HiveTableSource.java | 16 ++++++--
.../connectors/hive/HiveTableSourceITCase.java | 6 ++-
.../connectors/kafka/table/KafkaDynamicSink.java | 7 +++-
.../connectors/kafka/table/KafkaDynamicSource.java | 14 +++++--
.../kafka/table/KafkaDynamicTableFactoryTest.java | 5 ++-
.../table/UpsertKafkaDynamicTableFactoryTest.java | 8 +++-
...treamScanProvider.java => ProviderContext.java} | 30 ++++++++------
.../connector/sink/DataStreamSinkProvider.java | 34 ++++++++++++++--
.../connector/source/DataStreamScanProvider.java | 24 ++++++++++-
.../planner/connectors/CollectDynamicSink.java | 11 +++--
.../planner/connectors/ExternalDynamicSink.java | 21 +++++++++-
.../planner/connectors/ExternalDynamicSource.java | 45 ++++++++++++++++++---
.../connectors/TransformationScanProvider.java | 43 +++++++-------------
.../connectors/TransformationSinkProvider.java | 31 +++++++-------
.../plan/nodes/exec/common/CommonExecSink.java | 37 ++++++++++++++---
.../exec/common/CommonExecTableSourceScan.java | 19 ++++++++-
.../table/planner/factories/TestFileFactory.java | 10 ++++-
.../planner/factories/TestValuesTableFactory.java | 20 +++++++--
.../plan/nodes/exec/TransformationsTest.java | 43 --------------------
.../nodes/exec/common/CommonExecSinkITCase.java | 47 +++++++++-------------
.../stream/jsonplan/CalcJsonPlanITCase.java | 8 ++--
.../jsonplan/DeduplicationJsonPlanITCase.java | 1 +
.../stream/jsonplan/ExpandJsonPlanITCase.java | 8 ++--
.../jsonplan/GroupAggregateJsonPlanITCase.java | 29 ++++++-------
.../jsonplan/GroupWindowAggregateJsonITCase.java | 22 +++++-----
.../IncrementalAggregateJsonPlanITCase.java | 9 ++---
.../jsonplan/IntervalJoinJsonPlanITCase.java | 15 +++----
.../stream/jsonplan/JoinJsonPlanITCase.java | 41 ++++++++-----------
.../stream/jsonplan/LookupJoinJsonPlanITCase.java | 15 +++----
.../stream/jsonplan/TableSinkJsonPlanITCase.java | 10 ++---
.../stream/jsonplan/TableSourceJsonPlanITCase.java | 30 +++++---------
.../jsonplan/TemporalJoinJsonPlanITCase.java | 15 +++----
.../stream/jsonplan/TemporalSortJsonITCase.java | 14 +++----
.../stream/jsonplan/ValuesJsonPlanITCase.java | 8 ++--
.../jsonplan/WatermarkAssignerJsonPlanITCase.java | 7 +---
.../stream/jsonplan/WindowAggregateJsonITCase.java | 29 ++++++-------
.../jsonplan/WindowDeduplicateJsonITCase.java | 8 ++--
.../stream/jsonplan/WindowJoinJsonITCase.java | 8 ++--
.../jsonplan/WindowTableFunctionJsonITCase.java | 8 ++--
.../table/planner/utils/JsonPlanTestBase.java | 33 ++++++++++++++-
43 files changed, 490 insertions(+), 359 deletions(-)
copy
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/{source/DataStreamScanProvider.java
=> ProviderContext.java} (50%)
