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 fd9a1ba39ac [FLINK-38992] Expire associated state together for
non-time over windows
add 5f5003ad6fb [FLINK-38941][python] Add Python building blocks for async
Python scalar function
No new revisions were added by this update.
Summary of changes:
.../examples/table/async/async_scalar_function.py | 126 +++++++++
.../pyflink/fn_execution/beam/beam_operations.py | 10 +
.../fn_execution/beam/beam_operations_fast.pyx | 19 +-
.../fn_execution/beam/beam_operations_slow.py | 19 +-
.../pyflink/fn_execution/datastream/operations.py | 7 +
.../datastream/process/async_function/operation.py | 3 +-
.../datastream/process/async_function/queue.py | 12 +-
.../fn_execution/table/async_function}/__init__.py | 0
.../table/async_function/operations.py | 222 ++++++++++++++++
flink-python/pyflink/table/__init__.py | 3 +-
.../table/tests/test_async_scalar_function.py | 285 +++++++++++++++++++++
flink-python/pyflink/table/udf.py | 129 +++++++++-
flink-python/pyflink/testing/test_case_utils.py | 41 +++
flink-python/setup.py | 1 +
...unction.java => PythonAsyncScalarFunction.java} | 51 ++--
.../exec/common/CommonExecPythonAsyncCalc.java | 8 +
16 files changed, 874 insertions(+), 62 deletions(-)
create mode 100644
flink-python/pyflink/examples/table/async/async_scalar_function.py
copy {flink-end-to-end-tests/flink-python-test/python/datastream =>
flink-python/pyflink/fn_execution/table/async_function}/__init__.py (100%)
create mode 100644
flink-python/pyflink/fn_execution/table/async_function/operations.py
create mode 100644
flink-python/pyflink/table/tests/test_async_scalar_function.py
copy
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/python/{PythonScalarFunction.java
=> PythonAsyncScalarFunction.java} (74%)
