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 fa9f887 [FLINK-21696][docs] Add output parameter in
WatermarkGenerator scala sections
add a365bc5 [FLINK-21937][python] Support batch mode in Python DataStream
API for basic operations
No new revisions were added by this update.
Summary of changes:
flink-python/pyflink/common/configuration.py | 2 +-
flink-python/pyflink/common/execution_config.py | 2 +-
flink-python/pyflink/common/restart_strategy.py | 2 +-
flink-python/pyflink/common/serialization.py | 2 +-
.../pyflink/dataset/execution_environment.py | 2 +-
flink-python/pyflink/datastream/connectors.py | 2 +-
flink-python/pyflink/datastream/state_backend.py | 2 +-
.../datastream/stream_execution_environment.py | 22 +-
.../pyflink/datastream/tests/test_data_stream.py | 628 +++++++++++----------
.../pyflink/datastream/tests/test_state_backend.py | 2 +-
.../tests/test_stream_execution_environment.py | 12 -
flink-python/pyflink/table/expression.py | 2 +-
flink-python/pyflink/table/expressions.py | 2 +-
flink-python/pyflink/table/sinks.py | 9 +-
flink-python/pyflink/table/statement_set.py | 2 +-
flink-python/pyflink/table/table.py | 4 +-
flink-python/pyflink/table/table_environment.py | 6 +-
flink-python/pyflink/table/table_schema.py | 2 +-
.../table/tests/test_table_environment_api.py | 2 +-
flink-python/pyflink/table/types.py | 2 +-
flink-python/pyflink/table/udf.py | 10 +-
flink-python/pyflink/table/utils.py | 2 +-
flink-python/pyflink/testing/source_sink_utils.py | 9 +-
flink-python/pyflink/testing/test_case_utils.py | 27 +-
.../pyflink/util/{utils.py => java_utils.py} | 25 +-
.../apache/flink/python/util/PythonConfigUtil.java | 4 -
26 files changed, 435 insertions(+), 351 deletions(-)
rename flink-python/pyflink/util/{utils.py => java_utils.py} (90%)
