You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by he...@apache.org on 2020/03/10 11:36:29 UTC

[flink] branch master updated (8f8e358 -> 6f19fd2)

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 8f8e358  [FLINK-16167][python][doc] Improve python_shell document
     add 6f19fd2  [FLINK-16483][python] Add Python building blocks to make sure the basic functionality of vectorized Python UDF could work (#11342)

No new revisions were added by this update.

Summary of changes:
 flink-python/pyflink/fn_execution/ResettableIO.py  |  72 +++++++++
 flink-python/pyflink/fn_execution/coder_impl.py    |  43 ++++++
 flink-python/pyflink/fn_execution/coders.py        |  42 +++++-
 .../pyflink/table/tests/test_pandas_udf.py         | 162 +++++++++++++++++++++
 flink-python/pyflink/table/udf.py                  |  41 ++++--
 flink-python/setup.py                              |   3 +-
 .../AbstractArrowPythonScalarFunctionRunner.java   |   1 +
 7 files changed, 351 insertions(+), 13 deletions(-)
 create mode 100644 flink-python/pyflink/fn_execution/ResettableIO.py
 create mode 100644 flink-python/pyflink/table/tests/test_pandas_udf.py