|
|
|
FLINK-23754
|
FLINK-22913
Testing Python DataStream API chaining functionality
|
Dian Fu
|
Dian Fu
|
|
Closed |
Done
|
|
|
|
|
|
|
|
FLINK-23753
|
FLINK-22913
Add documentation about Python DataStream API chaining optimization
|
Dian Fu
|
Dian Fu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-23619
|
FLINK-22913
Remove PythonTimestampsAndWatermarksOperator
|
Dian Fu
|
Dian Fu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-23616
|
FLINK-22913
Support to chain the Python DataStream operators as much as possible
|
Dian Fu
|
Dian Fu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-23584
|
FLINK-22913
Introduce PythonCoProcessOperator and remove PythonCoFlatMapOperator & PythonCoMapOperator
|
Dian Fu
|
Dian Fu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-23578
|
FLINK-22913
Remove Python operators PythonFlatMapOperator/PythonMapOperator/PythonPartitionCustomOperator and use PythonProcessOperator instead
|
Dian Fu
|
Dian Fu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-23401
|
FLINK-22913
Separate data and timer connection into different channels for Python DataStream API operators
|
Dian Fu
|
Dian Fu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-23400
|
FLINK-22913
Support to decode a single record for the Python coder
|
Dian Fu
|
Dian Fu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-23213
|
FLINK-22913
Remove ProcessFunctionOperation
|
Dian Fu
|
Dian Fu
|
|
Closed |
Fixed
|
|
|
|
|