You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2020/02/19 17:50:47 UTC
[flink] branch master updated (57215c4 -> 80f40cf)
This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 57215c4 [FLINK-16162][build] Bump flink-shaded to 10.0
add 80f40cf [FLINK-16033][table-api] Construct expressions through factory methods (#11141)
No new revisions were added by this update.
Summary of changes:
.../table/api/OverWindowPartitionedOrdered.java | 2 +-
.../table/api/internal/TableEnvironmentImpl.java | 4 +-
.../{utils => }/ApiExpressionUtils.java | 44 ++++++++++++++++------
.../expressions/LocalReferenceExpression.java | 2 +-
.../table/expressions/LookupCallExpression.java | 2 +-
.../expressions/TableReferenceExpression.java | 2 +-
.../expressions/UnresolvedCallExpression.java | 4 +-
.../expressions/UnresolvedReferenceExpression.java | 2 +-
.../expressions/resolver/ExpressionResolver.java | 4 +-
.../expressions/resolver/LookupCallResolver.java | 4 +-
.../resolver/rules/ExpandColumnFunctionsRule.java | 4 +-
.../resolver/rules/OverWindowResolverRule.java | 2 +-
.../rules/QualifyBuiltInFunctionsRule.java | 3 +-
.../resolver/rules/ReferenceResolverRule.java | 2 +-
.../resolver/rules/ResolveCallByArgumentsRule.java | 2 +-
.../utils/OperationExpressionsUtils.java | 8 ++--
.../operations/utils/OperationTreeBuilder.java | 25 ++++++------
.../utils/factories/AggregateOperationFactory.java | 4 +-
.../utils/factories/AliasOperationUtils.java | 6 +--
.../utils/factories/CalculatedTableFactory.java | 2 +-
.../utils/factories/ColumnOperationUtils.java | 4 +-
.../table/sources/tsextractors/ExistingField.java | 2 +-
.../tsextractors/StreamRecordTimestamp.java | 2 +-
.../flink/table/operations/QueryOperationTest.java | 2 +-
.../org/apache/flink/table/api/expressionDsl.scala | 2 +-
.../expressions/DeclarativeExpressionResolver.java | 3 +-
.../planner/expressions/ExpressionBuilder.java | 2 +-
.../planner/expressions/SqlAggFunctionVisitor.java | 2 +-
.../converter/CustomizedConvertRule.java | 2 +-
.../functions/aggfunctions/AvgAggFunction.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/ListAggFunction.java | 2 +-
.../functions/aggfunctions/MaxAggFunction.java | 2 +-
.../functions/aggfunctions/MinAggFunction.java | 2 +-
.../functions/aggfunctions/RankAggFunction.java | 2 +-
.../aggfunctions/RankLikeAggFunctionBase.java | 4 +-
.../aggfunctions/RowNumberAggFunction.java | 2 +-
.../aggfunctions/SingleValueAggFunction.java | 2 +-
.../functions/aggfunctions/Sum0AggFunction.java | 2 +-
.../functions/aggfunctions/SumAggFunction.java | 2 +-
.../aggfunctions/SumWithRetractAggFunction.java | 2 +-
.../planner/plan/QueryOperationConverter.java | 2 +-
.../expressions/PlannerExpressionParserImpl.scala | 2 +-
.../codegen/agg/DeclarativeAggCodeGen.scala | 5 ++-
.../codegen/agg/batch/AggCodeGenHelper.scala | 3 +-
.../logical/LogicalWindowAggregateRuleBase.scala | 2 +-
.../planner/plan/utils/RexNodeExtractor.scala | 2 +-
.../table/planner/sources/TableSourceUtil.scala | 2 +-
.../planner/expressions/DecimalTypeTest.scala | 2 +-
.../planner/expressions/KeywordParseTest.scala | 2 +-
.../table/planner/expressions/MapTypeTest.scala | 2 +-
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 2 +-
.../planner/plan/utils/RexNodeExtractorTest.scala | 2 +-
.../table/planner/utils/testTableSources.scala | 2 +-
.../flink/table/plan/QueryOperationConverter.java | 4 +-
.../flink/table/api/internal/TableEnvImpl.scala | 8 ++--
.../expressions/PlannerExpressionParserImpl.scala | 2 +-
.../table/plan/util/RexProgramExtractor.scala | 2 +-
.../flink/table/sources/TableSourceUtil.scala | 2 +-
.../flink/table/descriptors/RowtimeTest.scala | 3 +-
.../flink/table/expressions/KeywordParseTest.scala | 2 +-
66 files changed, 132 insertions(+), 106 deletions(-)
rename flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/{utils => }/ApiExpressionUtils.java (79%)