You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by di...@apache.org on 2022/07/07 04:43:37 UTC
[flink] branch master updated (eb395309e04 -> bbd5a813e9c)
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 eb395309e04 [FLINK-27767][sql-gateway] Introduce Endpoint API and utils (#19849)
add bbd5a813e9c [FLINK-28393][python][avro] Support AvroInputFormat in PyFlink DataStream API
No new revisions were added by this update.
Summary of changes:
.../docs/connectors/datastream/formats/avro.md | 28 ++
.../docs/connectors/datastream/formats/parquet.md | 6 +-
.../docs/connectors/datastream/formats/avro.md | 28 ++
.../docs/connectors/datastream/formats/parquet.md | 6 +-
...ry_state_warning.html => py_download_link.html} | 18 +-
flink-python/docs/pyflink.datastream.rst | 6 +
flink-python/pom.xml | 10 -
.../connectors/tests/test_file_system.py | 530 +++++++++++++--------
.../pyflink/datastream/formats/__init__.py | 9 +
flink-python/pyflink/datastream/formats/avro.py | 65 ++-
.../datastream/{time_domain.py => formats/base.py} | 19 +-
flink-python/pyflink/datastream/formats/parquet.py | 15 +-
.../datastream/stream_execution_environment.py | 32 +-
flink-python/pyflink/datastream/utils.py | 12 +-
flink-python/setup.py | 1 +
.../AbstractDataStreamPythonFunctionOperator.java | 3 +-
.../AbstractOneInputPythonFunctionOperator.java | 10 +-
.../AbstractTwoInputPythonFunctionOperator.java | 10 +-
.../api/operators/python/timer/TimerUtils.java | 2 +-
.../flink/streaming/api/utils/ProtoUtils.java | 9 +-
.../flink/streaming/api/utils/PythonTypeUtils.java | 82 ++--
.../streaming/api/utils/PythonTypeUtilsTest.java | 15 +-
22 files changed, 626 insertions(+), 290 deletions(-)
copy docs/layouts/shortcodes/{query_state_warning.html => py_download_link.html} (57%)
copy flink-python/pyflink/datastream/{time_domain.py => formats/base.py} (71%)