This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 208de7c [FLINK-15161][table-common] Introduce TypeTransformation
interface and basic transformations (#10500)
new 9172a67 [hotfix][table] Rename UserFunctionsTypeHelper
new ec40d85 [FLINK-12283][table] Relax UDF constraints by using the
ClosureCleaner
new af4d880 [hotfix][table] Update function tests to use testing
infrastructure
new 966209a [hotfix][table] Use testing infrastacture in tests
The 4 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:
.../client/gateway/local/ExecutionContext.java | 27 +-
.../java/internal/StreamTableEnvironmentImpl.java | 14 +-
.../internal/StreamTableEnvironmentImplTest.java | 5 +-
.../table/api/internal/TableEnvironmentImpl.java | 20 +-
.../flink/table/catalog/FunctionCatalog.java | 38 +-
.../expressions/resolver/ExpressionResolver.java | 18 +-
.../resolver/rules/ResolveCallByArgumentsRule.java | 50 ++-
.../expressions/resolver/rules/ResolverRule.java | 6 +
...eHelper.java => UserDefinedFunctionHelper.java} | 50 ++-
.../operations/utils/OperationTreeBuilder.java | 36 +-
.../flink/table/catalog/FunctionCatalogTest.java | 2 +
.../flink/table/utils/TableEnvironmentMock.java | 12 +-
.../internal/StreamTableEnvironmentImpl.scala | 14 +-
.../internal/StreamTableEnvironmentImplTest.scala | 5 +-
.../org/apache/flink/table/api/expressionDsl.scala | 8 +-
.../functions/AggregateFunctionDefinition.java | 4 +
.../table/functions/ScalarFunctionDefinition.java | 4 +
.../TableAggregateFunctionDefinition.java | 4 +
.../table/functions/TableFunctionDefinition.java | 4 +
.../flink/table/functions/UserDefinedFunction.java | 2 +-
.../expressions/CallExpressionResolver.java | 1 +
.../planner/codegen/CodeGeneratorContext.scala | 2 +-
.../flink/table/planner/expressions/call.scala | 4 -
.../table/planner/functions/FunctionTestBase.java | 362 -----------------
.../operations/SqlToOperationConverterTest.java | 5 +-
.../planner/runtime/batch/sql/FunctionITCase.java | 39 --
.../planner/runtime/stream/sql/FunctionITCase.java | 390 ++++++++++++++++--
.../codegen/WatermarkGeneratorCodeGenTest.scala | 5 +-
.../metadata/AggCallSelectivityEstimatorTest.scala | 3 +-
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 8 +-
.../plan/metadata/SelectivityEstimatorTest.scala | 2 +-
.../planner/plan/utils/RexNodeExtractorTest.scala | 7 +-
.../planner/runtime/stream/table/CalcITCase.scala | 77 +++-
.../flink/table/planner/utils/TableTestBase.scala | 8 +-
.../flink/table/api/internal/TableEnvImpl.scala | 21 +-
.../apache/flink/table/codegen/CodeGenerator.scala | 2 +-
.../org/apache/flink/table/expressions/call.scala | 4 -
.../PushFilterIntoTableSourceScanRule.scala | 4 +-
.../table/runtime/aggregate/AggregateUtil.scala | 4 +-
.../flink/table/functions/FunctionTestBase.java | 436 ---------------------
.../table/runtime/batch/sql/FunctionITCase.java | 43 --
.../table/runtime/stream/sql/FunctionITCase.java | 431 +++++++++++++++++++-
.../table/sqlexec/SqlToOperationConverterTest.java | 5 +-
.../api/stream/StreamTableEnvironmentTest.scala | 2 +-
.../flink/table/api/stream/sql/AggregateTest.scala | 5 +-
.../flink/table/catalog/CatalogTableITCase.scala | 4 +-
.../flink/table/plan/RexProgramExtractorTest.scala | 2 +
.../batch/sql/PartitionableSinkITCase.scala | 11 +-
.../table/runtime/harness/HarnessTestBase.scala | 6 +-
.../table/runtime/stream/table/CalcITCase.scala | 88 +++++
.../apache/flink/table/utils/TableTestBase.scala | 2 +-
51 files changed, 1230 insertions(+), 1076 deletions(-)
rename
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/functions/{UserFunctionsTypeHelper.java
=> UserDefinedFunctionHelper.java} (77%)
delete mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/functions/FunctionTestBase.java
delete mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/batch/sql/FunctionITCase.java
delete mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/functions/FunctionTestBase.java
delete mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/runtime/batch/sql/FunctionITCase.java
