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 8b25ae6 [FLINK-26101][changelog] Avoid shared state registry to
discard multi-registered identical changelog state
add f547cea [hotfix][table-planner] Remove unused imports in
SetOpRewriteUtil
add 3652fa0 [hotfix][table-common] Clarify serializability of CatalogTable
add 7336672 [FLINK-25870][table] Introduce ContextResolvedFunction
similar to ContextResolvedTable
No new revisions were added by this update.
Summary of changes:
.../table/catalog/hive/util/HiveTableUtilTest.java | 8 +-
.../apache/flink/orc/OrcFileSystemFilterTest.java | 8 +-
.../table/catalog/ContextResolvedFunction.java | 170 ++++++
.../flink/table/catalog/ContextResolvedTable.java | 2 +-
.../flink/table/catalog/FunctionCatalog.java | 20 +-
.../apache/flink/table/catalog/FunctionLookup.java | 49 +-
.../table/expressions/ApiExpressionUtils.java | 19 +-
.../expressions/UnresolvedCallExpression.java | 57 +--
.../expressions/resolver/ExpressionResolver.java | 72 +--
.../expressions/resolver/LookupCallResolver.java | 8 +-
.../rules/QualifyBuiltInFunctionsRule.java | 23 +-
.../table/operations/CalculatedQueryOperation.java | 29 +-
.../operations/utils/CalculatedTableFactory.java | 5 +-
.../table/sources/tsextractors/ExistingField.java | 2 +-
.../flink/table/catalog/FunctionCatalogTest.java | 570 ++++++++++-----------
.../flink/table/catalog/SchemaResolutionTest.java | 6 +-
.../resolver/ExpressionResolverTest.java | 25 +-
.../flink/table/operations/QueryOperationTest.java | 2 +-
.../utils/ValuesOperationTreeBuilderTest.java | 25 +-
.../flink/table/utils/FunctionLookupMock.java | 12 +-
.../flink/table/catalog/CatalogBaseTable.java | 3 +-
.../apache/flink/table/catalog/CatalogTable.java | 10 +
.../flink/table/catalog/ResolvedCatalogTable.java | 16 +-
.../flink/table/expressions/CallExpression.java | 119 ++++-
.../flink/table/expressions/ExpressionTest.java | 6 +-
.../catalog/FunctionCatalogOperatorTable.java | 38 +-
.../planner/expressions/SqlAggFunctionVisitor.java | 17 +-
.../converter/FunctionDefinitionConvertRule.java | 18 +-
.../aggfunctions/SingleValueAggFunction.java | 2 +-
.../functions/bridging/BridgingSqlAggFunction.java | 50 +-
.../functions/bridging/BridgingSqlFunction.java | 67 ++-
.../planner/functions/bridging/BridgingUtils.java | 48 +-
.../planner/plan/QueryOperationConverter.java | 33 +-
.../exec/serde/AggregateCallJsonDeserializer.java | 8 +-
.../nodes/exec/serde/RexNodeJsonDeserializer.java | 7 +-
.../planner/plan/utils/RexNodeExtractor.scala | 38 +-
.../planner/plan/utils/SetOpRewriteUtil.scala | 2 -
.../table/planner/sources/TableSourceUtil.scala | 2 +-
.../plan/nodes/exec/serde/RexNodeSerdeTest.java | 12 +-
39 files changed, 863 insertions(+), 745 deletions(-)
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/ContextResolvedFunction.java
