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 eaa1cedb7f4 [FLINK-38308] Reduce logging of date parse errors in
DateTimeUtils
add 3fb23beb872 [FLINK-38559][python] Support unordered mode of async
function in Python DataStream API
No new revisions were added by this update.
Summary of changes:
flink-python/pyflink/datastream/__init__.py | 9 +-
.../pyflink/datastream/async_data_stream.py | 77 +++++
flink-python/pyflink/datastream/data_stream.py | 9 +-
flink-python/pyflink/datastream/functions.py | 84 ++++-
.../datastream/tests/test_async_function.py | 252 +++++++++++++++
.../pyflink/datastream/tests/test_data_stream.py | 9 +-
flink-python/pyflink/datastream/tests/test_util.py | 7 +
.../pyflink/datastream/tests/test_window.py | 9 +-
.../fn_execution/beam/beam_operations_fast.pyx | 29 +-
.../fn_execution/beam/beam_operations_slow.py | 26 +-
.../datastream/process/async_function}/__init__.py | 2 +
.../datastream/process/async_function/operation.py | 306 ++++++++++++++++++
.../datastream/process/async_function/queue.py | 345 +++++++++++++++++++++
flink-python/setup.py | 1 +
14 files changed, 1134 insertions(+), 31 deletions(-)
create mode 100644 flink-python/pyflink/datastream/async_data_stream.py
create mode 100644 flink-python/pyflink/datastream/tests/test_async_function.py
copy flink-python/pyflink/{common/tests =>
fn_execution/datastream/process/async_function}/__init__.py (97%)
create mode 100644
flink-python/pyflink/fn_execution/datastream/process/async_function/operation.py
create mode 100644
flink-python/pyflink/fn_execution/datastream/process/async_function/queue.py
