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

Posted to commits@flink.apache.org by di...@apache.org on 2020/09/25 09:13:58 UTC

[flink] branch master updated (f547f4c -> 8525c5c)

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 f547f4c  [FLINK-18906][task] Support StreamTaskSourceInput as BlockabledInput
     add 8525c5c  [FLINK-19134][python] Introduce BasicArrayTypeInfo and PrimitiveArrayTypeInfo for Python DataStream API

No new revisions were added by this update.

Summary of changes:
 flink-python/pyflink/common/typeinfo.py            | 110 +++++++++++++++++++++
 .../pyflink/datastream/tests/test_data_stream.py   |  37 +++++++
 .../fn_execution/beam/beam_coder_impl_slow.py      |  22 ++++-
 .../pyflink/fn_execution/beam/beam_coders.py       |   2 +-
 .../pyflink/fn_execution/coder_impl_fast.pxd       |   8 +-
 .../pyflink/fn_execution/coder_impl_fast.pyx       |  48 +++++++--
 flink-python/pyflink/fn_execution/coders.py        |  32 ++++--
 .../pyflink/fn_execution/flink_fn_execution_pb2.py |  30 +++---
 .../pyflink/fn_execution/tests/test_coders.py      |  11 ++-
 .../pyflink/fn_execution/tests/test_fast_coders.py |  12 ++-
 .../pyflink/proto/flink-fn-execution.proto         |   5 +-
 .../streaming/api/typeutils/PythonTypeUtils.java   |  68 ++++++++++++-
 .../table/runtime/typeutils/PythonTypeUtils.java   |   2 +-
 .../api/typeutils/PythonTypeUtilsTest.java         |  15 ++-
 14 files changed, 355 insertions(+), 47 deletions(-)