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 6241894 [FLINK-15291][table-common] Rename
WatermarkSepc#getWatermarkExpressionString to getWatermarkExpr (#10614)
new 09bcde2 [hotfix][table] Rename UserFunctionsTypeHelper
new 91629d6 [FLINK-12283][table] Relax UDF constraints by using the
ClosureCleaner
new 7fb9f9b [hotfix][table] Update function tests to use testing
infrastructure
new 524b443 [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
