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%)