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 de527fd [FLINK-20055][configuration] Add Datadog 'apikey' to list of
sensitive options
add 9a5165e [FLINK-19989][python] Add collect operation in Python
DataStream API
No new revisions were added by this update.
Summary of changes:
.../flink/api/java/typeutils/RowTypeInfo.java | 7 --
.../api/java/typeutils/TupleTypeInfoBase.java | 9 ++-
flink-python/pyflink/common/typeinfo.py | 62 ++++++++++++++++++
flink-python/pyflink/datastream/data_stream.py | 58 +++++++++++++++++
.../pyflink/datastream/tests/test_data_stream.py | 47 +++++++++++++
.../tests/test_stream_execution_environment.py | 11 ++--
flink-python/pyflink/datastream/utils.py | 76 ++++++++++++++++++++++
flink-python/pyflink/table/table_result.py | 4 +-
flink-python/pyflink/table/utils.py | 10 +--
.../flink/api/common/python/PythonBridgeUtils.java | 71 ++++++++++++++++++--
10 files changed, 328 insertions(+), 27 deletions(-)
create mode 100644 flink-python/pyflink/datastream/utils.py
