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/17 09:05:08 UTC
[flink] branch master updated (8f2385b -> 2f617d0)
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 8f2385b [FLINK-18974][docs-zh]Translate the 'User-Defined Functions' page of "Application Development's DataStream API" into Chinese (#13225)
add 2f617d0 [FLINK-17879][python] Update Python row serializer to support RowKind
No new revisions were added by this update.
Summary of changes:
.../python/datastream/functions.py | 7 +-
flink-python/pyflink/common/__init__.py | 3 +
flink-python/pyflink/common/types.py | 221 +++++++++++++++++++++
flink-python/pyflink/datastream/data_stream.py | 6 +-
.../pyflink/datastream/tests/test_data_stream.py | 13 +-
.../fn_execution/beam/beam_coder_impl_slow.py | 72 ++++---
.../pyflink/fn_execution/coder_impl_fast.pxd | 15 +-
.../pyflink/fn_execution/coder_impl_fast.pyx | 101 ++++++----
.../pyflink/fn_execution/tests/test_coders.py | 9 +-
.../pyflink/fn_execution/tests/test_fast_coders.py | 12 +-
flink-python/pyflink/table/__init__.py | 3 +-
flink-python/pyflink/table/tests/test_calc.py | 3 +-
.../pyflink/table/tests/test_pandas_conversion.py | 3 +-
.../pyflink/table/tests/test_pandas_udf.py | 3 +-
flink-python/pyflink/table/types.py | 173 +---------------
.../runtime/typeutils/python/PythonTypeUtils.java | 2 +-
.../table/runtime/typeutils/PythonTypeUtils.java | 2 +-
.../serializers/python/RowDataSerializer.java | 64 +++---
.../flink/python/util/PythonTypeUtilsTest.java | 2 +-
.../arrow/sources/RowArrowSourceFunctionTest.java | 2 +-
20 files changed, 421 insertions(+), 295 deletions(-)
create mode 100644 flink-python/pyflink/common/types.py