You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ku...@apache.org on 2019/09/28 13:27:16 UTC
[flink] branch master updated (3a49da6 -> 3267f50)
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 3a49da6 [FLINK-13992][coordination] Refactor Optional parameter in InputGateWithMetrics#updateMetrics
add bf3587d [FLINK-13656][sql-parser] Bump sql parser Calcite dependency to 1.21.0
add 4f0d804 [FLINK-13656][table-planner][table-planner-blink] Bump flink and blink planner pom and notice file Calcite version to 1.21.0
add d11d0cb [FLINK-13656][table-planner][table-planner-blink] Update implementation about match_recognize because of match partition keys structure change
add 8705ecd [FLINK-13656][table-planner] Update converter rule description
add b5a2d1d [FLINK-13656][table-planner][table-planner-blink] Update plan change for agg call distinct remove
add 1805511 [FLINK-13656][table-planner][table-planner-blink] Update file for Calcite API change
add 64a5e83 [FLINK-13656][table-planner-blink] Update plan change because of collapsed IS NOT DISTINCT FROM
add 3267f50 [FLINK-13656][table-planner][table-planner-blink] Update files for non equal join condition push down change after sql-to-rel conversion
No new revisions were added by this update.
Summary of changes:
NOTICE-binary | 8 +-
flink-table/flink-sql-parser/pom.xml | 5 +-
.../src/main/codegen/data/Parser.tdd | 42 +-
.../src/main/codegen/includes/parserImpls.ftl | 325 +--
.../calcite/sql/ExtendedSqlRowTypeNameSpec.java | 150 +
.../org/apache/calcite/sql/SqlMapTypeNameSpec.java | 103 +
.../java/org/apache/calcite/sql}/package-info.java | 10 +-
.../apache/flink/sql/parser/ExtendedSqlNode.java | 4 +-
.../flink/sql/parser/FlinkSqlDataTypeSpec.java | 325 ---
.../flink/sql/parser/ddl/SqlCreateTable.java | 12 +-
.../apache/flink/sql/parser/ddl/SqlCreateView.java | 4 +-
.../flink/sql/parser/ddl/SqlTableColumn.java | 8 +-
.../apache/flink/sql/parser/dml/RichSqlInsert.java | 4 +-
...rseException.java => SqlValidateException.java} | 11 +-
...Type.java => ExtendedSqlBasicTypeNameSpec.java} | 42 +-
.../type/ExtendedSqlCollectionTypeNameSpec.java | 129 +
.../flink/sql/parser/type/ExtendedSqlType.java | 42 -
.../apache/flink/sql/parser/type/SqlArrayType.java | 49 -
.../apache/flink/sql/parser/type/SqlBytesType.java | 38 -
.../apache/flink/sql/parser/type/SqlMapType.java | 59 -
.../apache/flink/sql/parser/type/SqlRowType.java | 94 -
.../flink/sql/parser/type/SqlStringType.java | 38 -
.../apache/flink/sql/parser/type/SqlTimeType.java | 73 -
.../flink/sql/parser/type/SqlTimestampType.java | 73 -
.../flink/sql/parser/FlinkDDLDataTypeTest.java | 206 +-
.../flink/sql/parser/FlinkSqlParserImplTest.java | 32 +-
flink-table/flink-table-planner-blink/pom.xml | 8 +-
.../java/org/apache/calcite/sql/SqlFunction.java | 322 +++
.../apache/calcite/sql2rel/RelDecorrelator.java | 2856 --------------------
.../operations/SqlToOperationConverter.java | 14 +-
...FlinkAggregateExpandDistinctAggregatesRule.java | 95 +-
.../plan/rules/logical/FlinkFilterJoinRule.java | 363 ---
.../logical/FlinkJoinPushExpressionsRule.java | 5 +-
.../rules/logical/FlinkJoinToMultiJoinRule.java | 594 ----
.../src/main/resources/META-INF/NOTICE | 4 +-
.../planner/calcite/FlinkLogicalRelFactories.scala | 6 +-
.../table/planner/calcite/FlinkPlannerImpl.scala | 34 +-
.../table/planner/calcite/FlinkRelBuilder.scala | 4 +-
.../table/planner/calcite/FlinkTypeFactory.scala | 22 +-
.../table/planner/calcite/FlinkTypeSystem.scala | 27 +-
.../calcite/RelTimeIndicatorConverter.scala | 5 +-
.../table/planner/codegen/ExprCodeGenerator.scala | 5 +
.../table/planner/codegen/MatchCodeGenerator.scala | 22 +-
.../planner/codegen/calls/ScalarOperatorGens.scala | 10 +
.../planner/plan/logical/MatchRecognize.scala | 3 +-
.../plan/nodes/logical/FlinkLogicalMatch.scala | 34 +-
.../nodes/physical/stream/StreamExecMatch.scala | 12 +-
.../planner/plan/rules/FlinkBatchRuleSets.scala | 6 +-
.../planner/plan/rules/FlinkStreamRuleSets.scala | 6 +-
.../physical/stream/StreamExecMatchRule.scala | 31 +-
.../table/planner/plan/utils/FlinkRelOptUtil.scala | 170 +-
.../planner/plan/batch/sql/DeadlockBreakupTest.xml | 2 +-
.../planner/plan/batch/sql/SetOperatorsTest.xml | 2 +-
.../batch/sql/agg/AggregateReduceGroupingTest.xml | 14 +-
.../plan/batch/sql/agg/DistinctAggregateTest.xml | 2 +-
.../plan/batch/sql/join/BroadcastHashJoinTest.xml | 60 +-
.../sql/join/BroadcastHashSemiAntiJoinTest.xml | 2 +-
.../plan/batch/sql/join/NestedLoopJoinTest.xml | 90 +-
.../batch/sql/join/NestedLoopSemiAntiJoinTest.xml | 16 +-
.../plan/batch/sql/join/SemiAntiJoinTest.xml | 16 +-
.../plan/batch/sql/join/ShuffledHashJoinTest.xml | 90 +-
.../sql/join/ShuffledHashSemiAntiJoinTest.xml | 2 +-
.../plan/batch/sql/join/SortMergeJoinTest.xml | 92 +-
.../batch/sql/join/SortMergeSemiAntiJoinTest.xml | 2 +-
.../table/planner/plan/batch/table/JoinTest.xml | 12 +-
.../logical/AggregateReduceGroupingRuleTest.xml | 22 +-
...nkAggregateExpandDistinctAggregatesRuleTest.xml | 4 +-
.../rules/logical/FlinkAggregateRemoveRuleTest.xml | 2 +-
.../plan/rules/logical/FlinkFilterJoinRuleTest.xml | 64 +-
.../logical/subquery/SubQueryAntiJoinTest.xml | 40 +-
.../logical/subquery/SubQuerySemiJoinTest.xml | 24 +-
.../planner/plan/stream/sql/SetOperatorsTest.xml | 4 +-
.../planner/plan/stream/sql/join/JoinTest.xml | 24 +-
.../plan/stream/sql/join/SemiAntiJoinTest.xml | 18 +-
.../planner/plan/stream/table/AggregateTest.xml | 4 +-
.../table/planner/plan/stream/table/JoinTest.xml | 8 +-
.../planner/expressions/TemporalTypesTest.scala | 2 +-
.../FlinkAggregateJoinTransposeRuleTest.scala | 4 +-
.../rules/logical/FlinkFilterJoinRuleTest.scala | 8 +-
.../logical/FlinkJoinToMultiJoinRuleTest.scala | 6 +-
.../JoinDependentConditionDerivationRuleTest.scala | 5 +-
.../RewriteMultiJoinConditionRuleTest.scala | 6 +-
flink-table/flink-table-planner/pom.xml | 8 +-
.../java/org/apache/calcite/sql/SqlFunction.java | 322 +++
.../calcite/sql/validate/SqlValidatorImpl.java | 34 +
.../table/sqlexec/SqlToOperationConverter.java | 14 +-
.../src/main/resources/META-INF/NOTICE | 4 +-
.../flink/table/calcite/FlinkPlannerImpl.scala | 32 +-
.../flink/table/calcite/FlinkRelBuilder.scala | 4 +-
.../table/calcite/RelTimeIndicatorConverter.scala | 5 +-
.../flink/table/codegen/MatchCodeGenerator.scala | 18 +-
.../flink/table/plan/logical/MatchRecognize.scala | 4 +-
.../table/plan/nodes/CommonMatchRecognize.scala | 16 +-
.../plan/nodes/datastream/DataStreamMatch.scala | 9 +-
.../plan/nodes/logical/FlinkLogicalMatch.scala | 36 +-
.../table/plan/rules/dataSet/DataSetCalcRule.scala | 2 +-
.../plan/rules/dataSet/DataSetCorrelateRule.scala | 2 +-
.../plan/rules/dataSet/DataSetDistinctRule.scala | 2 +-
.../table/plan/rules/dataSet/DataSetJoinRule.scala | 2 +-
.../rules/dataSet/DataSetSingleRowJoinRule.scala | 2 +-
.../plan/rules/dataSet/DataSetValuesRule.scala | 2 +-
.../plan/rules/datastream/DataStreamCalcRule.scala | 2 +-
.../rules/datastream/DataStreamCorrelateRule.scala | 2 +-
.../plan/rules/datastream/DataStreamJoinRule.scala | 2 +-
.../rules/datastream/DataStreamMatchRule.scala | 32 +-
.../plan/rules/datastream/DataStreamSortRule.scala | 2 +-
.../DataStreamTemporalTableJoinRule.scala | 2 +-
.../rules/datastream/DataStreamValuesRule.scala | 2 +-
.../datastream/DataStreamWindowJoinRule.scala | 2 +-
.../api/batch/sql/DistinctAggregateTest.scala | 19 +-
.../flink/table/api/batch/sql/JoinTest.scala | 20 +-
.../api/stream/sql/DistinctAggregateTest.scala | 2 +-
.../flink/table/api/stream/sql/JoinTest.scala | 12 +-
.../table/api/stream/table/AggregateTest.scala | 2 +-
.../runtime/harness/TemporalJoinHarnessTest.scala | 5 +-
flink-table/pom.xml | 1 +
116 files changed, 2064 insertions(+), 5752 deletions(-)
create mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/calcite/sql/ExtendedSqlRowTypeNameSpec.java
create mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/calcite/sql/SqlMapTypeNameSpec.java
copy {flink-tests/src/test/java/org/apache/flink/test/manual => flink-table/flink-sql-parser/src/main/java/org/apache/calcite/sql}/package-info.java (73%)
delete mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/FlinkSqlDataTypeSpec.java
rename flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/error/{SqlParseException.java => SqlValidateException.java} (79%)
rename flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/type/{SqlMultisetType.java => ExtendedSqlBasicTypeNameSpec.java} (53%)
create mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/type/ExtendedSqlCollectionTypeNameSpec.java
delete mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/type/ExtendedSqlType.java
delete mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/type/SqlArrayType.java
delete mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/type/SqlBytesType.java
delete mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/type/SqlMapType.java
delete mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/type/SqlRowType.java
delete mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/type/SqlStringType.java
delete mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/type/SqlTimeType.java
delete mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/type/SqlTimestampType.java
create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/calcite/sql/SqlFunction.java
delete mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/calcite/sql2rel/RelDecorrelator.java
delete mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkFilterJoinRule.java
delete mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkJoinToMultiJoinRule.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql/SqlFunction.java