[flink] branch master updated (392dcb0 -> 5119fec)

[di...@apache.org]

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 392dcb0  [FLINK-23149][table-code-splitter] Introduce the new Java code splitter module
     add 5119fec  [FLINK-23213][python] Refactor the code strucuture of Python DataStream API

No new revisions were added by this update.

Summary of changes:
 flink-python/pyflink/datastream/timerservice.py    |  93 ------
 .../pyflink/fn_execution/beam/beam_operations.py   |  98 +++---
 .../fn_execution/beam/beam_operations_fast.pyx     |   2 +-
 .../fn_execution/beam/beam_operations_slow.py      |   2 +-
 .../fn_execution/datastream/input_handler.py       | 108 +++++++
 .../pyflink/fn_execution/datastream/operations.py  | 346 +++++++++++++++++++++
 .../output_handler.py}                             |  12 +-
 ...yed_process_function.py => process_function.py} |  27 +-
 .../fn_execution/datastream/runtime_context.py     |  26 +-
 .../{ => fn_execution}/datastream/timerservice.py  |  75 +----
 .../{ => datastream}/timerservice_impl.py          |  34 +-
 .../datastream/window}/__init__.py                 |   0
 .../datastream/{ => window}/merging_window_set.py  |   0
 .../datastream/{ => window}/window_operator.py     |   4 +-
 .../pyflink/fn_execution/{ => table}/operations.py | 195 ++----------
 .../pyflink/fn_execution/table/state_data_view.py  |   2 +-
 .../fn_execution/table/window_aggregate_fast.pyx   |   2 +-
 .../fn_execution/table/window_aggregate_slow.py    |   4 +-
 .../pyflink/fn_execution/table/window_context.py   |   4 +-
 .../pyflink/fn_execution/utils/input_handler.py    | 219 -------------
 .../fn_execution/{ => utils}/operation_utils.py    | 228 +-------------
 flink-python/setup.py                              |   1 +
 .../java/org/apache/flink/python/Constants.java    |  27 ++
 .../python/OneInputPythonFunctionOperator.java     |   6 +-
 .../python/PythonKeyedCoProcessOperator.java       |   6 +-
 .../python/PythonKeyedProcessOperator.java         |   6 +-
 .../operators/python/PythonProcessOperator.java    |   6 +-
 .../python/TwoInputPythonFunctionOperator.java     |   6 +-
 28 files changed, 654 insertions(+), 885 deletions(-)
 create mode 100644 flink-python/pyflink/fn_execution/datastream/input_handler.py
 create mode 100644 flink-python/pyflink/fn_execution/datastream/operations.py
 rename flink-python/pyflink/fn_execution/{utils/output_factory.py => datastream/output_handler.py} (86%)
 rename flink-python/pyflink/fn_execution/datastream/{keyed_process_function.py => process_function.py} (78%)
 copy flink-python/pyflink/{ => fn_execution}/datastream/timerservice.py (59%)
 rename flink-python/pyflink/fn_execution/{ => datastream}/timerservice_impl.py (81%)
 copy flink-python/pyflink/{util => fn_execution/datastream/window}/__init__.py (100%)
 rename flink-python/pyflink/fn_execution/datastream/{ => window}/merging_window_set.py (100%)
 rename flink-python/pyflink/fn_execution/datastream/{ => window}/window_operator.py (99%)
 rename flink-python/pyflink/fn_execution/{ => table}/operations.py (79%)
 delete mode 100644 flink-python/pyflink/fn_execution/utils/input_handler.py
 rename flink-python/pyflink/fn_execution/{ => utils}/operation_utils.py (54%)
 create mode 100644 flink-python/src/main/java/org/apache/flink/python/Constants.java