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 e45723b [FLINK-23573][runtime][test] Add
RecipientUnreachableException to the whitelist for e2e log checkings.
new 25e1345 [hotfix][python] Fix the input value is None in
IterableCoderImpl
new 1a1c567 [FLINK-22911][python] Rework
from_data_stream/create_temporary_view/to_data_stream of TableEnvironment in
Python Table API
new 8b4a5bf [FLINK-22911][python] Add
to_changelog_stream/from_changelog_stream to StreamTableEnvironment in Python
Table API
new 0f03fb4 [FLINK-22911][python] Optimize the output format of
RowTypeInfo and ExternalTypeInfo
new a1ebbad [FLINK-22911][python] Optimize from_collection/from_elements
to support RowKind and Instant
new b5ca9ee [FLINK-22911][python][doc] Add documentation how to interact
with DataStream API in PyFlink
The 6 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../docs/dev/python/datastream/data_types.md | 1 +
.../dev/python/table/conversion_of_data_stream.md} | 8 +-
docs/content.zh/docs/dev/table/data_stream_api.md | 612 ++++++++++++++++++-
.../docs/dev/python/datastream/data_types.md | 1 +
.../table/{sql.md => conversion_of_data_stream.md} | 8 +-
docs/content/docs/dev/table/data_stream_api.md | 651 ++++++++++++++++++++-
flink-python/pyflink/common/__init__.py | 5 +-
flink-python/pyflink/common/time.py | 32 +
flink-python/pyflink/common/typeinfo.py | 106 +++-
flink-python/pyflink/common/types.py | 16 +
flink-python/pyflink/datastream/data_stream.py | 19 +-
.../pyflink/datastream/tests/test_data_stream.py | 2 +-
flink-python/pyflink/datastream/utils.py | 18 +-
.../pyflink/fn_execution/coder_impl_fast.pxd | 6 +
.../pyflink/fn_execution/coder_impl_fast.pyx | 36 +-
.../pyflink/fn_execution/coder_impl_slow.py | 33 +-
flink-python/pyflink/fn_execution/coders.py | 19 +-
.../pyflink/fn_execution/flink_fn_execution_pb2.py | 54 +-
.../pyflink/fn_execution/tests/test_coders.py | 8 +-
.../pyflink/proto/flink-fn-execution.proto | 1 +
flink-python/pyflink/table/__init__.py | 4 +-
.../changelog_mode.py} | 41 +-
flink-python/pyflink/table/expressions.py | 2 +-
flink-python/pyflink/table/table_environment.py | 436 +++++++++++++-
.../table/tests/test_table_environment_api.py | 263 ++++++++-
flink-python/pyflink/table/types.py | 47 +-
flink-python/pyflink/table/utils.py | 4 +-
.../flink/streaming/api/utils/PythonTypeUtils.java | 25 +-
.../planner/utils/python/PythonTableUtils.scala | 13 +-
29 files changed, 2294 insertions(+), 177 deletions(-)
copy docs/{content/docs/dev/python/table/sql.md =>
content.zh/docs/dev/python/table/conversion_of_data_stream.md} (89%)
copy docs/content/docs/dev/python/table/{sql.md =>
conversion_of_data_stream.md} (89%)
copy flink-python/pyflink/{common/input_dependency_constraint.py =>
table/changelog_mode.py} (57%)
