This is an automated email from the ASF dual-hosted git repository.
hxb pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 08b2048 [FLINK-23347][docs][datatream] Updated operators windowAll
description
add df4fa8a [FLINK-22865][python] Optimize state serialize/deserialize in
PyFlink
No new revisions were added by this update.
Summary of changes:
flink-python/pyflink/common/serializer.py | 4 +
flink-python/pyflink/datastream/data_stream.py | 7 +-
flink-python/pyflink/datastream/state.py | 26 +----
.../pyflink/datastream/tests/test_data_stream.py | 35 +++----
flink-python/pyflink/datastream/window.py | 22 ++--
.../fn_execution/beam/beam_coder_impl_fast.pyx | 8 +-
.../fn_execution/beam/beam_coder_impl_slow.py | 5 +-
.../pyflink/fn_execution/beam/beam_coders.py | 29 +-----
.../fn_execution/beam/beam_operations_fast.pyx | 2 +-
.../beam/{beam_stream.pxd => beam_stream_fast.pxd} | 0
.../beam/{beam_stream.pyx => beam_stream_fast.pyx} | 0
.../pyflink/fn_execution/beam/beam_stream_slow.py | 25 +++--
.../pyflink/fn_execution/coder_impl_fast.pxd | 9 +-
.../pyflink/fn_execution/coder_impl_fast.pyx | 45 ++++++++-
.../pyflink/fn_execution/coder_impl_slow.py | 51 +++++++++-
flink-python/pyflink/fn_execution/coders.py | 111 ++++++++++++++++++++-
.../pyflink/fn_execution/datastream/operations.py | 4 +-
.../fn_execution/datastream/runtime_context.py | 25 +++--
.../datastream/window/merging_window_set.py | 10 +-
.../datastream/window/window_operator.py | 12 +--
flink-python/pyflink/fn_execution/state_impl.py | 2 +
flink-python/pyflink/fn_execution/stream_slow.py | 3 +-
.../pyflink/fn_execution/table/aggregate_fast.pyx | 15 ++-
.../pyflink/fn_execution/table/aggregate_slow.py | 15 ++-
.../pyflink/fn_execution/table/operations.py | 4 +-
.../pyflink/fn_execution/table/state_data_view.py | 4 +-
.../fn_execution/table/window_aggregate_fast.pyx | 12 +--
.../fn_execution/table/window_aggregate_slow.py | 12 +--
.../pyflink/fn_execution/table/window_assigner.py | 5 +-
.../pyflink/fn_execution/table/window_context.py | 15 ++-
.../pyflink/fn_execution/table/window_trigger.py | 2 +-
flink-python/setup.py | 8 +-
32 files changed, 336 insertions(+), 191 deletions(-)
rename flink-python/pyflink/fn_execution/beam/{beam_stream.pxd =>
beam_stream_fast.pxd} (100%)
rename flink-python/pyflink/fn_execution/beam/{beam_stream.pyx =>
beam_stream_fast.pyx} (100%)
copy flink-dist/src/main/flink-bin/conf/zoo.cfg =>
flink-python/pyflink/fn_execution/beam/beam_stream_slow.py (65%)
