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 0198805 [FLINK-19542][k8s] Implement LeaderElectionService and
LeaderRetrievalService based on Kubernetes API
add 473d2c5 [FLINK-19821][python] Add ProcessFunction and timer access in
Python DataStream API
No new revisions were added by this update.
Summary of changes:
.../python/datastream/data_stream_job.py | 90 ++++--
.../python/datastream/functions.py | 24 +-
.../test-scripts/test_pyflink.sh | 66 +++--
flink-python/pyflink/datastream/__init__.py | 8 +-
flink-python/pyflink/datastream/data_stream.py | 39 ++-
flink-python/pyflink/datastream/functions.py | 159 +++++++++++
.../pyflink/datastream/time_domain.py | 16 +-
.../fn_execution/beam/beam_coder_impl_slow.py | 8 +-
.../pyflink/fn_execution/beam/beam_coders.py | 16 +-
.../pyflink/fn_execution/beam/beam_operations.py | 43 ++-
.../pyflink/fn_execution/coder_impl_fast.pxd | 5 +-
.../pyflink/fn_execution/coder_impl_fast.pyx | 7 +-
flink-python/pyflink/fn_execution/coders.py | 18 +-
.../pyflink/fn_execution/flink_fn_execution_pb2.py | 120 ++++----
.../pyflink/fn_execution/operation_utils.py | 50 ++++
flink-python/pyflink/fn_execution/operations.py | 73 ++++-
.../pyflink/proto/flink-fn-execution.proto | 2 +
.../apache/flink/python/util/PythonConfigUtil.java | 4 +-
.../functions/python/DataStreamPythonFunction.java | 2 +-
.../python/PythonPartitionCustomOperator.java | 8 +-
.../python/PythonProcessFunctionOperator.java | 309 +++++++++++++++++++++
.../api/operators/python/PythonReduceOperator.java | 6 +-
.../StatelessOneInputPythonFunctionOperator.java | 10 +-
.../StatelessTwoInputPythonFunctionOperator.java | 10 +-
...ava => BeamDataStreamPythonFunctionRunner.java} | 12 +-
.../python/beam/BeamPythonFunctionRunner.java | 8 +-
.../streaming/api/utils/PythonOperatorUtils.java | 18 ++
27 files changed, 941 insertions(+), 190 deletions(-)
copy flink-clients/src/test/resources/testconfig/flink-conf.yaml =>
flink-python/pyflink/datastream/time_domain.py (72%)
create mode 100644
flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/PythonProcessFunctionOperator.java
rename
flink-python/src/main/java/org/apache/flink/streaming/api/runners/python/beam/{BeamDataStreamStatelessPythonFunctionRunner.java
=> BeamDataStreamPythonFunctionRunner.java} (86%)
