This is an automated email from the ASF dual-hosted git repository.
hequn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 6d72cc0 [FLINK-18688][table-planner-blink] Fix binary row writing
with incorrect order in ProjectionCodeGenerator by removing for loop
optimization
add b8d2ed7 [FLINK-18766][python] Support add_sink() for Python
DataStream API. (#13094)
No new revisions were added by this update.
Summary of changes:
flink-python/pyflink/datastream/data_stream.py | 87 +++++++++++++++++++++-
flink-python/pyflink/datastream/functions.py | 32 ++++++++
.../pyflink/datastream/tests/test_data_stream.py | 67 +++++++++--------
.../tests/test_stream_execution_environment.py | 14 ++--
flink-python/pyflink/datastream/tests/test_util.py | 27 ++-----
.../python/util/DataStreamTestCollectSink.java | 18 +++--
6 files changed, 176 insertions(+), 69 deletions(-)
