This is an automated email from the ASF dual-hosted git repository.
kurt pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from bde1251 [hotfix][table-planner] Remove unused import in CalcITCase
add 7c11822 [FLINK-14381][table-planner] Remove dynamic partition shuffle
support in legacy planner
add fcc4b7f [FLINK-14381][table-planner-blink] User table factory and
catalog table to test partition source and sink
add ad4fd63 [FLINK-14381][table-planner-blink] Get partition keys from
catalog table for PartitionableTableSink
add 8e0d8ac [FLINK-14381][table-planner-blink] Get partition keys from
catalog table for PartitionableTableSource
add 335c4f7 [FLINK-14381][table-planner-blink] Remove
getPartitionFieldNames in PartitionableTableSource and PartitionableTableSink
No new revisions were added by this update.
Summary of changes:
.../flink/connectors/hive/HiveTableSink.java | 3 +-
.../flink/connectors/hive/HiveTableSource.java | 5 -
.../flink/table/sinks/PartitionableTableSink.java | 16 +-
.../table/sources/PartitionableTableSource.java | 14 +-
.../planner/catalog/DatabaseCalciteSchema.java | 6 +-
.../planner/plan/QueryOperationConverter.java | 3 +-
.../calcite/RelTimeIndicatorConverter.scala | 3 +-
.../table/planner/delegation/PlannerBase.scala | 39 ++---
.../planner/plan/nodes/calcite/LogicalSink.scala | 13 +-
.../plan/nodes/logical/FlinkLogicalSink.scala | 16 +-
.../PushFilterIntoTableSourceScanRule.scala | 5 +-
.../PushPartitionIntoTableSourceScanRule.scala | 30 ++--
.../PushProjectIntoTableSourceScanRule.scala | 3 +-
.../rules/physical/batch/BatchExecSinkRule.scala | 43 ++---
.../rules/physical/stream/StreamExecSinkRule.scala | 41 ++---
.../planner/plan/schema/TableSourceTable.scala | 17 +-
.../flink/table/planner/sinks/TableSinkUtils.scala | 42 ++---
.../org.apache.flink.table.factories.TableFactory | 2 +
.../planner/plan/batch/sql/TableSourceTest.scala | 4 +-
.../PushPartitionIntoTableSourceScanRuleTest.scala | 4 +-
.../planner/plan/stream/sql/TableSourceTest.scala | 4 +-
.../batch/sql/PartitionableSinkITCase.scala | 182 +++++++++++++--------
.../runtime/batch/sql/TableSourceITCase.scala | 6 +-
.../runtime/stream/sql/TableSourceITCase.scala | 4 +-
.../table/planner/utils/testTableSources.scala | 83 +++++++++-
.../table/api/internal/BatchTableEnvImpl.scala | 26 +--
.../flink/table/api/internal/TableEnvImpl.scala | 4 +-
.../apache/flink/table/planner/StreamPlanner.scala | 32 +---
.../apache/flink/table/sinks/TableSinkUtils.scala | 28 +---
.../batch/sql/PartitionableSinkITCase.scala | 139 +++-------------
30 files changed, 373 insertions(+), 444 deletions(-)
