Step 1 of 4: Choose Issues

Cancel

T Patch Info Key Summary Assignee Reporter P Status Resolution Created Updated Due Development
Sub-task FLINK-21632

FLINK-21111 Add NamespacedStateView and PerWindowStateDataViewStore

Huang Xingbo Huang Xingbo Major Resolved Resolved  
Sub-task FLINK-21294

FLINK-21111 Support state access API for the map/flat_map operation of Python ConnectedStreams

Wei Zhong Wei Zhong Major Closed Fixed  
Sub-task FLINK-21242

FLINK-21111 Support state access API for the map/flat_map/filter/reduce operations of Python KeyedStream

Wei Zhong Wei Zhong Major Closed Fixed  
Sub-task FLINK-21199

FLINK-21111 Introduce InternalTimerService In PyFlink

Huang Xingbo Huang Xingbo Major Resolved Resolved  
Sub-task FLINK-21192

FLINK-21111 Support setting namespace in RemoteKeyedStateBackend

Huang Xingbo Huang Xingbo Major Resolved Resolved  
Sub-task FLINK-21180

FLINK-21111 Move the state module from 'pyflink.common' to 'pyflink.datastream'

Wei Zhong Wei Zhong Major Closed Fixed  
Sub-task FLINK-21179

FLINK-21111 Make sure that the open/close methods of the Python DataStream Function are not implemented when using in ReducingState and AggregatingState

Unassigned Wei Zhong Major Open Unresolved  
Sub-task FLINK-21170

FLINK-21111 Add internal state hierarchy in PyFlink

Huang Xingbo Huang Xingbo Major Resolved Resolved  
Sub-task FLINK-21115

FLINK-21111 Add AggregatingState and corresponding StateDescriptor for Python DataStream API

Wei Zhong Wei Zhong Major Closed Fixed  
Sub-task FLINK-21114

FLINK-21111 Add ReducingState and corresponding StateDescriptor for Python DataStream API

Wei Zhong Wei Zhong Major Closed Resolved  
Sub-task FLINK-21113

FLINK-21111 Add State access API for KeyedStream RuntimeContext.

Unassigned Shuiqiang Chen Major Closed Implemented  
Sub-task FLINK-21112

FLINK-21111 Add ValueState/ListState/MapState and corresponding StateDescriptors for Python DataStream API

Shuiqiang Chen Shuiqiang Chen Major Closed Fixed  

Cancel