|
|
|
FLINK-21966
|
FLINK-18761
Support Kinesis connector in Python DataStream API.
|
pengmd
|
Shuiqiang Chen
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-18985
|
FLINK-18761
Update the Sphinx doc for Python DataStream API.
|
Hequn Cheng
|
Hequn Cheng
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-18984
|
FLINK-18761
Add tutorial documentation for Python DataStream API
|
Hequn Cheng
|
Hequn Cheng
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-18966
|
FLINK-18761
Support key_by() on ConnectedStreams for Python DataStream API
|
Hequn Cheng
|
Hequn Cheng
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-18954
|
FLINK-18761
Add documentation for connectors in Python DataStream API.
|
Unassigned
|
Hequn Cheng
|
|
Closed |
Done
|
|
|
|
|
|
|
|
FLINK-18953
|
FLINK-18761
Add documentation for DataTypes in Python DataStream API
|
Hequn Cheng
|
Hequn Cheng
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-18951
|
FLINK-18761
Add documentation for dependency management in Python DataStream API.
|
Shuiqiang Chen
|
Shuiqiang Chen
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-18950
|
FLINK-18761
Add documentation for Operations in Python DataStream API.
|
Shuiqiang Chen
|
Shuiqiang Chen
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-18949
|
FLINK-18761
Support Streaming File Sink for Python DataStream API
|
Hequn Cheng
|
Hequn Cheng
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-18948
|
FLINK-18761
Add end to end test for Python DataStream API
|
Shuiqiang Chen
|
Hequn Cheng
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-18947
|
FLINK-18761
Support partitionCustom() operation for Python DataStream API
|
shuiqiangchen
|
Hequn Cheng
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-18946
|
FLINK-18761
Support Cassandra connector for Python DataStream API
|
Shuiqiang Chen
|
Shuiqiang Chen
|
|
Closed |
Later
|
|
|
|
|
|
|
|
FLINK-18945
|
FLINK-18761
Support CoFlatMap for Python DataStream API
|
Hequn Cheng
|
Hequn Cheng
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-18944
|
FLINK-18761
Support JDBC connector for Python DataStream API
|
Shuiqiang Chen
|
Shuiqiang Chen
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-18943
|
FLINK-18761
Support CoMapFunction for Python DataStream API
|
Hequn Cheng
|
Hequn Cheng
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-18888
|
FLINK-18761
Support execute_async for StreamExecutionEnvironment.
|
Shuiqiang Chen
|
Shuiqiang Chen
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-18887
|
FLINK-18761
Add ElasticSearch connector for Python DataStream API
|
Luning Wang
|
Shuiqiang Chen
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-18886
|
FLINK-18761
Support Kafka connectors for Python DataStream API
|
Shuiqiang Chen
|
Shuiqiang Chen
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-18885
|
FLINK-18761
Add partitioning interfaces for Python DataStream API.
|
Shuiqiang Chen
|
Shuiqiang Chen
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-18884
|
FLINK-18761
Add chaining strategy and slot sharing group interfaces for Python DataStream API
|
Shuiqiang Chen
|
Shuiqiang Chen
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-18883
|
FLINK-18761
Support reduce() operation for Python KeyedStream.
|
Hequn Cheng
|
Hequn Cheng
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-18879
|
FLINK-18761
Support Row Serialization and Deserialization schemas for DataStream source/sink
|
Shuiqiang Chen
|
Shuiqiang Chen
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-18878
|
FLINK-18761
Support dependency management for Python StreamExecutionEnvironment.
|
Shuiqiang Chen
|
Shuiqiang Chen
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-18874
|
FLINK-18761
Support conversion between Table and DataStream
|
Shuiqiang Chen
|
Shuiqiang Chen
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-18866
|
FLINK-18761
Support filter() operation for Python DataStream API.
|
Shuiqiang Chen
|
Shuiqiang Chen
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-18864
|
FLINK-18761
Support key_by() operation for Python DataStream API
|
Shuiqiang Chen
|
Shuiqiang Chen
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-18863
|
FLINK-18761
Support read_text_file() and print() interface for Python DataStream API.
|
Shuiqiang Chen
|
Shuiqiang Chen
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-18861
|
FLINK-18761
Support add_source() to get a DataStream for Python StreamExecutionEnvironment
|
Shuiqiang Chen
|
Shuiqiang Chen
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-18766
|
FLINK-18761
Support add_sink() for Python DataStream API
|
Shuiqiang Chen
|
Hequn Cheng
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-18765
|
FLINK-18761
Support map() and flat_map() for Python DataStream API
|
Shuiqiang Chen
|
Hequn Cheng
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-18764
|
FLINK-18761
Support from_collection for Python DataStream API
|
Shuiqiang Chen
|
Hequn Cheng
|
|
Closed |
Resolved
|
|
|
|
|
|
|
|
FLINK-18763
|
FLINK-18761
Support basic TypeInformation for Python DataStream API
|
Shuiqiang Chen
|
Hequn Cheng
|
|
Closed |
Resolved
|
|
|
|
|