This is an automated email from the ASF dual-hosted git repository.
hequn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 008e0af [FLINK-17338] Increase timeouts on LocalExecutorITCase
add e3faf63 [FLINK-16485][python] Support vectorized Python UDF in batch
mode of old planner (#11859)
No new revisions were added by this update.
Summary of changes:
.../pyflink/table/tests/test_pandas_udf.py | 22 +++++++++-
...va => AbstractPythonScalarFunctionFlatMap.java} | 46 ++++---------------
.../AbstractPythonStatelessFunctionFlatMap.java | 7 +++
.../python/PythonScalarFunctionFlatMap.java | 51 +---------------------
.../python/PythonTableFunctionFlatMap.java | 15 +++----
.../arrow/ArrowPythonScalarFunctionFlatMap.java} | 41 +++++++++--------
.../plan/nodes/dataset/DataSetPythonCalc.scala | 16 +++++--
7 files changed, 78 insertions(+), 120 deletions(-)
copy
flink-python/src/main/java/org/apache/flink/table/runtime/functions/python/{PythonScalarFunctionFlatMap.java
=> AbstractPythonScalarFunctionFlatMap.java} (65%)
copy
flink-python/src/main/java/org/apache/flink/table/runtime/{operators/python/scalar/arrow/ArrowPythonScalarFunctionOperator.java
=> functions/python/arrow/ArrowPythonScalarFunctionFlatMap.java} (75%)
