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 7e2f01a [FLINK-23594][python] Ignore
test_from_and_to_data_stream_event_time temporarily
add e8baf16 [hotfix][table] Support new type system in flatten() function
add 6aa0a8a [FLINK-15804][table-api-scala] Use new type inference for
implicit ScalarFunction calls in Scala
No new revisions were added by this update.
Summary of changes:
.../resolver/rules/ResolveCallByArgumentsRule.java | 55 +-
.../table/api/ImplicitExpressionConversions.scala | 4 +-
.../ConstructedAccessFunctionsITCase.java | 95 +++-
.../utils/JavaUserDefinedScalarFunctions.java | 49 +-
.../table/planner/plan/batch/table/CalcTest.xml | 6 +-
.../table/planner/plan/batch/table/JoinTest.xml | 4 +-
.../testPythonCalc.out | 2 +-
.../testPythonFunctionInWhereClause.out | 4 +-
.../testJoinWithFilter.out | 2 +-
.../testPythonTableFunction.out | 2 +-
.../plan/rules/logical/PythonMapMergeRuleTest.xml | 36 +-
.../table/planner/plan/stream/table/CalcTest.xml | 6 +-
.../planner/plan/stream/table/CorrelateTest.xml | 2 +-
.../plan/stream/table/OverAggregateTest.xml | 2 +-
.../plan/stream/table/TableAggregateTest.xml | 2 +-
.../UserDefinedFunctionValidationTest.scala | 61 ---
.../UserDefinedScalarFunctionTest.scala | 585 ---------------------
.../utils/userDefinedScalarFunctions.scala | 293 +----------
.../table/planner/plan/batch/table/CalcTest.scala | 5 -
.../table/planner/plan/batch/table/JoinTest.scala | 2 +-
.../rules/logical/PythonCalcSplitRuleTest.scala | 20 +-
.../planner/runtime/stream/table/CalcITCase.scala | 2 +-
.../runtime/stream/table/CorrelateITCase.scala | 2 +-
.../flink/table/planner/utils/TableTestBase.scala | 4 +
.../planner/utils/UserDefinedTableFunctions.scala | 9 +-
25 files changed, 206 insertions(+), 1048 deletions(-)
delete mode 100644
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/validation/UserDefinedFunctionValidationTest.scala
delete mode 100644
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/expressions/UserDefinedScalarFunctionTest.scala
