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 cef3aa136ed [FLINK-28464][python][csv] Support CsvReaderFormat
add 7a9016cca05 [FLINK-27587][python] Support keyed co-broadcast processing
No new revisions were added by this update.
Summary of changes:
flink-python/pyflink/datastream/__init__.py | 7 +-
flink-python/pyflink/datastream/data_stream.py | 124 +++++++++-----
flink-python/pyflink/datastream/functions.py | 181 ++++++++++++++++++---
.../pyflink/datastream/tests/test_data_stream.py | 84 +++++++++-
.../pyflink/fn_execution/datastream/operations.py | 59 ++++++-
.../fn_execution/datastream/process_function.py | 102 +++++++++---
.../pyflink/fn_execution/flink_fn_execution_pb2.py | 84 +++++-----
.../pyflink/proto/flink-fn-execution.proto | 1 +
.../apache/flink/python/util/PythonConfigUtil.java | 30 +++-
.../PythonBatchCoBroadcastProcessOperator.java | 4 +-
...ythonBatchKeyedCoBroadcastProcessOperator.java} | 24 +--
.../python/PythonBroadcastStateTransformation.java | 24 +--
...> PythonKeyedBroadcastStateTransformation.java} | 54 +++---
...thonBroadcastStateTransformationTranslator.java | 2 +
...yedBroadcastStateTransformationTranslator.java} | 37 +++--
15 files changed, 609 insertions(+), 208 deletions(-)
copy
flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/{PythonBatchCoBroadcastProcessOperator.java
=> PythonBatchKeyedCoBroadcastProcessOperator.java} (76%)
copy
flink-python/src/main/java/org/apache/flink/streaming/api/transformations/python/{PythonBroadcastStateTransformation.java
=> PythonKeyedBroadcastStateTransformation.java} (57%)
copy
flink-python/src/main/java/org/apache/flink/streaming/runtime/translators/python/{PythonBroadcastStateTransformationTranslator.java
=> PythonKeyedBroadcastStateTransformationTranslator.java} (72%)
