This is an automated email from the ASF dual-hosted git repository.
godfrey pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from d32ca07 [FLINK-22310][table-planner-blink] Fix the incorrect
deserialization result of LogicalWindowJsonDeserializer
add c6147f2 [FLINK-21627][table-planner-blink] The digest of TableScan
should consider table hints
add d98d731 [FLINK-21627][table-planner-blink] The digest of Sink should
consider table hints
No new revisions were added by this update.
Summary of changes:
.../calcite/rel/logical/LogicalTableScan.java | 137 +++++++++++++++++++++
.../table/planner/connectors/DynamicSinkUtils.java | 12 +-
.../PushFilterInCalcIntoTableSourceScanRule.java | 3 +-
.../logical/PushLimitIntoTableSourceScanRule.java | 3 +-
.../PushWatermarkIntoTableSourceScanRuleBase.java | 3 +-
.../planner/calcite/FlinkLogicalRelFactories.scala | 2 +
.../calcite/RelTimeIndicatorConverter.scala | 2 +
.../table/planner/delegation/PlannerBase.scala | 7 ++
.../planner/plan/nodes/calcite/LegacySink.scala | 6 +
.../plan/nodes/calcite/LogicalLegacySink.scala | 21 +++-
.../planner/plan/nodes/calcite/LogicalSink.scala | 7 +-
.../table/planner/plan/nodes/calcite/Sink.scala | 30 +++--
.../logical/FlinkLogicalDataStreamTableScan.scala | 25 ++--
.../nodes/logical/FlinkLogicalLegacySink.scala | 12 +-
.../FlinkLogicalLegacyTableSourceScan.scala | 20 +--
.../plan/nodes/logical/FlinkLogicalSink.scala | 8 +-
.../logical/FlinkLogicalTableSourceScan.scala | 19 +--
.../batch/BatchPhysicalBoundedStreamScan.scala | 10 +-
.../physical/batch/BatchPhysicalLegacySink.scala | 8 +-
.../batch/BatchPhysicalLegacyTableSourceScan.scala | 6 +-
.../nodes/physical/batch/BatchPhysicalSink.scala | 13 +-
.../batch/BatchPhysicalTableSourceScan.scala | 6 +-
.../CommonPhysicalLegacyTableSourceScan.scala | 8 +-
.../common/CommonPhysicalTableSourceScan.scala | 8 +-
.../stream/StreamPhysicalDataStreamScan.scala | 10 +-
.../physical/stream/StreamPhysicalLegacySink.scala | 8 +-
.../StreamPhysicalLegacyTableSourceScan.scala | 8 +-
.../nodes/physical/stream/StreamPhysicalSink.scala | 15 ++-
.../stream/StreamPhysicalTableSourceScan.scala | 6 +-
.../batch/BatchPhysicalBoundedStreamScanRule.scala | 7 +-
.../batch/BatchPhysicalLegacySinkRule.scala | 25 ++--
.../BatchPhysicalLegacyTableSourceScanRule.scala | 1 +
.../physical/batch/BatchPhysicalSinkRule.scala | 35 +++---
.../batch/BatchPhysicalTableSourceScanRule.scala | 1 +
.../stream/StreamPhysicalDataStreamScanRule.scala | 1 +
.../stream/StreamPhysicalLegacySinkRule.scala | 25 ++--
.../StreamPhysicalLegacyTableSourceScanRule.scala | 1 +
.../physical/stream/StreamPhysicalSinkRule.scala | 35 +++---
.../stream/StreamPhysicalTableSourceScanRule.scala | 1 +
.../table/planner/plan/utils/RelExplainUtil.scala | 27 +++-
.../planner/factories/TestValuesTableFactory.java | 42 ++++++-
.../planner/plan/batch/sql/LegacySinkTest.xml | 24 ++++
.../plan/batch/sql/LegacyTableSourceTest.xml | 38 ++++--
.../table/planner/plan/batch/sql/TableSinkTest.xml | 24 ++++
.../planner/plan/batch/sql/TableSourceTest.xml | 73 +++++++++++
.../planner/plan/batch/sql/join/LookupJoinTest.xml | 130 ++++++-------------
.../table/planner/plan/hint/OptionsHintTest.xml | 48 ++++----
.../rules/logical/CalcRankTransposeRuleTest.xml | 12 +-
.../logical/RankNumberColumnRemoveRuleTest.xml | 8 +-
.../planner/plan/batch/sql/LegacySinkTest.scala | 37 ++++++
.../plan/batch/sql/LegacyTableSourceTest.scala | 46 +++++++
.../planner/plan/batch/sql/TableSinkTest.scala | 45 ++++++-
.../planner/plan/batch/sql/TableSourceTest.scala | 113 +++++++++++++++++
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 11 +-
.../plan/metadata/FlinkRelMdUniqueKeysTest.scala | 5 +
.../batch/sql/LegacyTableSourceITCase.scala | 54 +++++++-
.../runtime/batch/sql/TableSinkITCase.scala | 79 ++++++++++++
.../runtime/batch/sql/TableSourceITCase.scala | 81 +++++++++++-
.../flink/table/planner/utils/TableTestBase.scala | 13 +-
.../table/planner/utils/testTableSourceSinks.scala | 26 +++-
.../calcite/rel/logical/LogicalTableScan.java | 137 +++++++++++++++++++++
61 files changed, 1341 insertions(+), 287 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/calcite/rel/logical/LogicalTableScan.java
create mode 100644
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/TableSinkITCase.scala
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/calcite/rel/logical/LogicalTableScan.java
