This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 61f9ffece97 [FLINK-37002][table] Migrate `DecomposeGroupingSetsRule`
to java
add 64f7824f084 [FLINK-38882][table] Introduce rules for async python
scalar function
No new revisions were added by this update.
Summary of changes:
.../pyflink/fn_execution/flink_fn_execution_pb2.py | 216 ++++++++--------
.../fn_execution/flink_fn_execution_pb2.pyi | 20 +-
.../pyflink/proto/flink-fn-execution.proto | 11 +
.../async/PythonAsyncScalarFunctionOperator.java | 107 ++++++++
.../BatchExecPythonAsyncCalc.java} | 33 +--
.../exec/common/CommonExecPythonAsyncCalc.java | 286 +++++++++++++++++++++
.../processor/ForwardHashExchangeProcessor.java | 2 +
...honCalc.java => StreamExecPythonAsyncCalc.java} | 36 +--
...java => StreamPhysicalPythonAsyncCalcRule.java} | 57 +++-
.../planner/plan/utils/ExecNodeMetadataUtil.java | 2 +
...lc.scala => BatchPhysicalPythonAsyncCalc.scala} | 12 +-
...c.scala => StreamPhysicalPythonAsyncCalc.scala} | 12 +-
.../planner/plan/rules/FlinkBatchRuleSets.scala | 20 ++
.../planner/plan/rules/FlinkStreamRuleSets.scala | 1 +
.../batch/BatchPhysicalPythonAsyncCalcRule.scala | 100 +++++++
.../batch/BatchPhysicalPythonCalcRule.scala | 4 +-
.../stream/StreamPhysicalPythonCalcRule.scala | 4 +-
...nTest.java => PythonAsyncCalcJsonPlanTest.java} | 108 ++++----
.../exec/testutils/RestoreTestCompleteness.java | 2 +
.../utils/JavaUserDefinedScalarFunctions.java | 35 +++
.../plan/batch/table/PythonAsyncCalcTest.xml | 166 ++++++++++++
.../testChainingPythonAsyncFunctions.out} | 49 ++--
.../testMultiplePythonAsyncFunctions.out} | 56 ++--
.../testPythonAsyncCalc.out} | 12 +-
.../testPythonAsyncFunctionInWhereClause.out} | 28 +-
...stPythonAsyncFunctionMixedWithJavaFunction.out} | 81 ++----
...onAsyncFunctionMixedWithSyncPythonFunction.out} | 54 ++--
.../plan/stream/table/PythonAsyncCalcTest.xml | 166 ++++++++++++
.../plan/batch/table/PythonAsyncCalcTest.scala | 85 ++++++
.../plan/stream/table/PythonAsyncCalcTest.scala | 85 ++++++
30 files changed, 1490 insertions(+), 360 deletions(-)
create mode 100644
flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/scalar/async/PythonAsyncScalarFunctionOperator.java
copy
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/{stream/StreamExecPythonCalc.java
=> batch/BatchExecPythonAsyncCalc.java} (67%)
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecPythonAsyncCalc.java
copy
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/{StreamExecPythonCalc.java
=> StreamExecPythonAsyncCalc.java} (70%)
copy
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/physical/stream/{StreamPhysicalAsyncCalcRule.java
=> StreamPhysicalPythonAsyncCalcRule.java} (51%)
copy
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchPhysicalPythonCalc.scala
=> BatchPhysicalPythonAsyncCalc.scala} (89%)
copy
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamPhysicalPythonCalc.scala
=> StreamPhysicalPythonAsyncCalc.scala} (88%)
create mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/batch/BatchPhysicalPythonAsyncCalcRule.scala
copy
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/{PythonOverAggregateJsonPlanTest.java
=> PythonAsyncCalcJsonPlanTest.java} (52%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/batch/table/PythonAsyncCalcTest.xml
copy
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/{PythonCalcJsonPlanTest_jsonplan/testPythonFunctionInWhereClause.out
=> PythonAsyncCalcJsonPlanTest_jsonplan/testChainingPythonAsyncFunctions.out}
(83%)
copy
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/{PythonCalcJsonPlanTest_jsonplan/testPythonFunctionInWhereClause.out
=> PythonAsyncCalcJsonPlanTest_jsonplan/testMultiplePythonAsyncFunctions.out}
(80%)
copy
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/{PythonCalcJsonPlanTest_jsonplan/testPythonCalc.out
=> PythonAsyncCalcJsonPlanTest_jsonplan/testPythonAsyncCalc.out} (90%)
copy
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/{PythonCalcJsonPlanTest_jsonplan/testPythonFunctionInWhereClause.out
=>
PythonAsyncCalcJsonPlanTest_jsonplan/testPythonAsyncFunctionInWhereClause.out}
(88%)
copy
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/{PythonCalcJsonPlanTest_jsonplan/testPythonFunctionInWhereClause.out
=>
PythonAsyncCalcJsonPlanTest_jsonplan/testPythonAsyncFunctionMixedWithJavaFunction.out}
(73%)
copy
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/{PythonCalcJsonPlanTest_jsonplan/testPythonFunctionInWhereClause.out
=>
PythonAsyncCalcJsonPlanTest_jsonplan/testPythonAsyncFunctionMixedWithSyncPythonFunction.out}
(82%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/stream/table/PythonAsyncCalcTest.xml
create mode 100644
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/batch/table/PythonAsyncCalcTest.scala
create mode 100644
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/table/PythonAsyncCalcTest.scala
