You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ja...@apache.org on 2019/08/09 06:38:27 UTC
[flink] branch master updated (421f0a5 -> bf37130)
This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 421f0a5 [FLINK-13523][table-planner-blink] Refactor AVG aggregate function to keep it compatible with old planner
add c649c8b [FLINK-13587][table-planner-blink] Introduces a framework to reuse code of "explainTerms" to generate operator names
add bf37130 [FLINK-13587][table-planner-blink] Fix some operator names are not set in blink planner
No new revisions were added by this update.
Summary of changes:
.../plan/utils/RelDescriptionWriterImpl.java | 107 +++++++++++++++++
.../planner/codegen/CorrelateCodeGenerator.scala | 7 +-
.../table/planner/delegation/BatchPlanner.scala | 2 +-
.../table/planner/delegation/StreamPlanner.scala | 2 +-
.../table/planner/plan/nodes/FlinkRelNode.scala | 20 +++-
.../table/planner/plan/nodes/calcite/Expand.scala | 22 ++--
.../planner/plan/nodes/common/CommonCalc.scala | 7 +-
.../plan/nodes/common/CommonLookupJoin.scala | 6 +-
.../plan/nodes/common/CommonPhysicalJoin.scala | 7 +-
.../plan/nodes/physical/batch/BatchExecCalc.scala | 3 +-
.../nodes/physical/batch/BatchExecCorrelate.scala | 4 +-
.../nodes/physical/batch/BatchExecExpand.scala | 3 +-
.../batch/BatchExecGroupAggregateBase.scala | 14 +--
.../physical/batch/BatchExecHashAggregate.scala | 5 -
.../batch/BatchExecHashAggregateBase.scala | 4 +-
.../nodes/physical/batch/BatchExecHashJoin.scala | 12 +-
.../batch/BatchExecHashWindowAggregate.scala | 4 -
.../batch/BatchExecHashWindowAggregateBase.scala | 4 +-
.../plan/nodes/physical/batch/BatchExecLimit.scala | 7 +-
.../batch/BatchExecLocalHashAggregate.scala | 2 -
.../batch/BatchExecLocalHashWindowAggregate.scala | 4 -
.../batch/BatchExecLocalSortAggregate.scala | 3 -
.../batch/BatchExecLocalSortWindowAggregate.scala | 2 -
.../physical/batch/BatchExecNestedLoopJoin.scala | 13 +-
.../physical/batch/BatchExecOverAggregate.scala | 6 +-
.../plan/nodes/physical/batch/BatchExecRank.scala | 10 +-
.../plan/nodes/physical/batch/BatchExecSort.scala | 2 +-
.../physical/batch/BatchExecSortAggregate.scala | 6 -
.../batch/BatchExecSortAggregateBase.scala | 4 +-
.../nodes/physical/batch/BatchExecSortLimit.scala | 9 +-
.../physical/batch/BatchExecSortMergeJoin.scala | 10 +-
.../batch/BatchExecSortWindowAggregate.scala | 5 -
.../batch/BatchExecSortWindowAggregateBase.scala | 4 +-
.../nodes/physical/batch/BatchExecValues.scala | 1 +
.../nodes/physical/stream/StreamExecCalc.scala | 2 +-
.../physical/stream/StreamExecCorrelate.scala | 1 +
.../physical/stream/StreamExecDeduplicate.scala | 13 +-
.../nodes/physical/stream/StreamExecExpand.scala | 3 +-
.../stream/StreamExecGlobalGroupAggregate.scala | 2 +-
.../physical/stream/StreamExecGroupAggregate.scala | 2 +-
.../stream/StreamExecGroupWindowAggregate.scala | 10 +-
.../StreamExecIncrementalGroupAggregate.scala | 2 +-
.../nodes/physical/stream/StreamExecJoin.scala | 9 +-
.../nodes/physical/stream/StreamExecLimit.scala | 2 +-
.../stream/StreamExecLocalGroupAggregate.scala | 2 +-
.../nodes/physical/stream/StreamExecMatch.scala | 2 +-
.../physical/stream/StreamExecOverAggregate.scala | 2 +-
.../nodes/physical/stream/StreamExecRank.scala | 16 +--
.../nodes/physical/stream/StreamExecSort.scala | 2 +-
.../physical/stream/StreamExecSortLimit.scala | 9 +-
.../physical/stream/StreamExecTemporalJoin.scala | 8 +-
.../physical/stream/StreamExecTemporalSort.scala | 4 +-
.../nodes/physical/stream/StreamExecValues.scala | 1 +
.../stream/StreamExecWatermarkAssigner.scala | 18 +--
.../physical/stream/StreamExecWindowJoin.scala | 11 +-
.../planner/plan/utils/ExecNodePlanDumper.scala | 2 +-
.../table/planner/plan/utils/FlinkRelOptUtil.scala | 2 +-
.../table/planner/plan/utils/RelExplainUtil.scala | 81 +++----------
.../flink/table/planner/plan/utils/ScanUtil.scala | 5 +-
.../resources/explain/testGetStatsFromCatalog.out | 6 +-
.../apache/flink/table/api/batch/ExplainTest.xml | 104 ++++++++--------
.../apache/flink/table/api/stream/ExplainTest.xml | 132 ++++++++++-----------
.../table/planner/plan/batch/sql/LimitTest.xml | 8 +-
.../planner/plan/batch/sql/SetOperatorsTest.xml | 6 +-
.../table/planner/plan/batch/sql/SortLimitTest.xml | 8 +-
.../table/planner/plan/batch/sql/UnnestTest.xml | 20 ++--
.../table/planner/plan/batch/sql/ValuesTest.xml | 22 ++--
.../plan/batch/sql/join/BroadcastHashJoinTest.xml | 2 +-
.../plan/batch/sql/join/NestedLoopJoinTest.xml | 6 +-
.../plan/batch/sql/join/SortMergeJoinTest.xml | 2 +-
.../logical/CalcPruneAggregateCallRuleTest.xml | 10 +-
.../rules/logical/FlinkAggregateRemoveRuleTest.xml | 8 +-
.../rules/logical/FlinkLimit0RemoveRuleTest.xml | 18 +--
.../rules/logical/FlinkPruneEmptyRulesTest.xml | 2 +-
.../plan/rules/logical/LogicalUnnestRuleTest.xml | 20 ++--
.../logical/ProjectPruneAggregateCallRuleTest.xml | 4 +-
.../logical/subquery/SubQuerySemiJoinTest.xml | 4 +-
.../table/planner/plan/stream/sql/LimitTest.xml | 24 ++--
.../plan/stream/sql/MiniBatchIntervalInferTest.xml | 30 ++---
.../table/planner/plan/stream/sql/RankTest.xml | 4 +-
.../planner/plan/stream/sql/SetOperatorsTest.xml | 6 +-
.../planner/plan/stream/sql/SortLimitTest.xml | 32 ++---
.../table/planner/plan/stream/sql/UnnestTest.xml | 20 ++--
.../table/planner/plan/stream/sql/ValuesTest.xml | 22 ++--
.../planner/plan/stream/sql/join/JoinTest.xml | 2 +-
.../plan/stream/sql/join/WindowJoinTest.xml | 2 +-
.../flink/table/planner/utils/TableTestBase.scala | 26 ++--
87 files changed, 507 insertions(+), 575 deletions(-)
create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/utils/RelDescriptionWriterImpl.java