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 c3f2ad8 [FLINK-12809][table-api] Introduce PartitionableTableSink for supporting writing data into partitions new 6161043 [FLINK-13028][table-api-java] Extract legacy type inference logic new 272ac71 [FLINK-13028][table-api-java] Remove planner expression from ExpressionResolver new 8c1968a [FLINK-13028][table-api-java] Refactor local over windows new 14fe641 [FLINK-13028][table] Refactor expression package structure new 036c549 [FLINK-13028][table-api-java] Merge flatten and call resolution rule The 5 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../table/api/OverWindowPartitionedOrdered.java | 2 +- .../table/api/internal/TableEnvironmentImpl.java | 2 +- .../apache/flink/table/api/internal/TableImpl.java | 2 +- .../PlannerExpressionParser.java | 8 +- .../table/delegation/PlannerTypeInferenceUtil.java | 75 ++++++++ .../flink/table/expressions/ExpressionParser.java | 1 + .../expressions/resolver}/ExpressionResolver.java | 137 ++++---------- .../expressions/resolver/LocalOverWindow.java | 75 ++++++++ .../{ => resolver}/LookupCallResolver.java | 6 +- .../resolver}/lookups/FieldReferenceLookup.java | 2 +- .../lookups/TableReferenceLookup.java | 2 +- .../resolver}/rules/ExpandColumnFunctionsRule.java | 8 +- .../resolver}/rules/LookupCallByNameRule.java | 4 +- .../resolver}/rules/OverWindowResolverRule.java | 68 +++++-- .../rules/QualifyBuiltInFunctionsRule.java | 2 +- .../resolver}/rules/ReferenceResolverRule.java | 7 +- .../rules/ResolveCallByArgumentsRule.java | 209 +++++++++------------ .../expressions/resolver}/rules/ResolverRule.java | 20 +- .../expressions/resolver}/rules/ResolverRules.java | 7 +- .../resolver}/rules/RuleExpressionVisitor.java | 6 +- .../rules/StarReferenceFlatteningRule.java | 2 +- .../{ => utils}/ApiExpressionDefaultVisitor.java | 13 +- .../{ => utils}/ApiExpressionUtils.java | 11 +- .../ResolvedExpressionDefaultVisitor.java | 10 +- .../operations/OperationExpressionsUtils.java | 10 +- .../flink/table/typeutils/FieldInfoUtils.java | 2 +- .../flink/table/operations/QueryOperationTest.java | 2 +- .../flink/table/expressions/ExpressionBuilder.java | 1 + .../functions/aggfunctions/AvgAggFunction.java | 2 +- .../functions/aggfunctions/ConcatAggFunction.java | 2 +- .../functions/aggfunctions/Count1AggFunction.java | 2 +- .../functions/aggfunctions/CountAggFunction.java | 2 +- .../aggfunctions/DeclarativeAggregateFunction.java | 2 +- .../functions/aggfunctions/IncrSumAggFunction.java | 2 +- .../IncrSumWithRetractAggFunction.java | 2 +- .../functions/aggfunctions/LeadLagAggFunction.java | 2 +- .../functions/aggfunctions/MaxAggFunction.java | 2 +- .../functions/aggfunctions/MinAggFunction.java | 2 +- .../functions/aggfunctions/RankAggFunction.java | 2 +- .../aggfunctions/RankLikeAggFunctionBase.java | 2 +- .../aggfunctions/RowNumberAggFunction.java | 2 +- .../aggfunctions/SingleValueAggFunction.java | 2 +- .../functions/aggfunctions/Sum0AggFunction.java | 2 +- .../functions/aggfunctions/SumAggFunction.java | 2 +- .../aggfunctions/SumWithRetractAggFunction.java | 2 +- .../table/codegen/agg/DeclarativeAggCodeGen.scala | 4 +- .../table/codegen/agg/batch/AggCodeGenHelper.scala | 3 +- .../codegen/agg/batch/HashAggCodeGenHelper.scala | 3 +- .../logical/LogicalWindowAggregateRuleBase.scala | 2 +- .../flink/table/plan/util/RexNodeExtractor.scala | 2 +- .../flink/table/sources/TableSourceUtil.scala | 2 +- .../table/sources/tsextractors/ExistingField.scala | 2 +- .../plan/metadata/FlinkRelMdHandlerTestBase.scala | 2 +- .../table/plan/util/RexNodeExtractorTest.scala | 2 +- .../apache/flink/table/util/testTableSources.scala | 2 +- .../expressions/PlannerTypeInferenceUtilImpl.java | 140 ++++++++++++++ .../table/expressions/rules/FlattenCallRule.java | 90 --------- .../operations/AggregateOperationFactory.java | 6 +- .../table/operations/AliasOperationUtils.java | 8 +- .../table/operations/CalculatedTableFactory.java | 4 +- .../table/operations/ColumnOperationUtils.java | 6 +- .../table/operations/JoinOperationFactory.java | 2 +- .../operations/OperationTreeBuilderFactory.java | 2 +- .../operations/ProjectionOperationFactory.java | 4 +- .../table/operations/SortOperationFactory.java | 4 +- .../flink/table/plan/QueryOperationConverter.java | 4 +- .../table/api/internal/BatchTableEnvImpl.scala | 3 +- .../flink/table/api/internal/TableEnvImpl.scala | 2 +- .../flink/table/api/scala/expressionDsl.scala | 2 +- .../flink/table/expressions/ExpressionBridge.scala | 1 + .../expressions/PlannerExpressionParserImpl.scala | 3 +- .../operations/OperationTreeBuilderImpl.scala | 8 +- .../flink/table/plan/logical/groupWindows.scala | 15 +- .../table/plan/util/RexProgramExtractor.scala | 2 +- .../flink/table/api/batch/table/CalcTest.scala | 1 + .../flink/table/expressions/KeywordParseTest.scala | 2 +- 76 files changed, 608 insertions(+), 453 deletions(-) rename flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/{expressions => delegation}/PlannerExpressionParser.java (87%) create mode 100644 flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/delegation/PlannerTypeInferenceUtil.java rename flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/expressions => flink-table-api-java/src/main/java/org/apache/flink/table/expressions/resolver}/ExpressionResolver.java (72%) create mode 100644 flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/resolver/LocalOverWindow.java rename flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/{ => resolver}/LookupCallResolver.java (87%) rename flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/expressions => flink-table-api-java/src/main/java/org/apache/flink/table/expressions/resolver}/lookups/FieldReferenceLookup.java (98%) rename flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/{ => resolver}/lookups/TableReferenceLookup.java (95%) rename flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/expressions => flink-table-api-java/src/main/java/org/apache/flink/table/expressions/resolver}/rules/ExpandColumnFunctionsRule.java (96%) rename flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/expressions => flink-table-api-java/src/main/java/org/apache/flink/table/expressions/resolver}/rules/LookupCallByNameRule.java (92%) rename flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/expressions => flink-table-api-java/src/main/java/org/apache/flink/table/expressions/resolver}/rules/OverWindowResolverRule.java (55%) rename flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/expressions => flink-table-api-java/src/main/java/org/apache/flink/table/expressions/resolver}/rules/QualifyBuiltInFunctionsRule.java (97%) rename flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/expressions => flink-table-api-java/src/main/java/org/apache/flink/table/expressions/resolver}/rules/ReferenceResolverRule.java (92%) rename flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/expressions => flink-table-api-java/src/main/java/org/apache/flink/table/expressions/resolver}/rules/ResolveCallByArgumentsRule.java (59%) rename flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/expressions => flink-table-api-java/src/main/java/org/apache/flink/table/expressions/resolver}/rules/ResolverRule.java (80%) rename flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/expressions => flink-table-api-java/src/main/java/org/apache/flink/table/expressions/resolver}/rules/ResolverRules.java (92%) rename flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/expressions => flink-table-api-java/src/main/java/org/apache/flink/table/expressions/resolver}/rules/RuleExpressionVisitor.java (84%) rename flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/expressions => flink-table-api-java/src/main/java/org/apache/flink/table/expressions/resolver}/rules/StarReferenceFlatteningRule.java (97%) rename flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/{ => utils}/ApiExpressionDefaultVisitor.java (80%) rename flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/{ => utils}/ApiExpressionUtils.java (87%) rename flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/{ => utils}/ResolvedExpressionDefaultVisitor.java (76%) create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/expressions/PlannerTypeInferenceUtilImpl.java delete mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/expressions/rules/FlattenCallRule.java