|
|
|
FLINK-36117
|
FLINK-34974
Implement AsyncKeyedStateBackend for RocksDBKeyedStateBackend and HeapKeyedStateBackend.
|
wang qian
|
wang qian
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-36096
|
FLINK-34974
Add synchronous interfaces for State V2 API.
|
wang qian
|
wang qian
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-35858
|
FLINK-34974
Namespace support for async state
|
Zakelly Lan
|
Zakelly Lan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-35356
|
FLINK-34974
Async reducing state
|
Zakelly Lan
|
Zakelly Lan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-35355
|
FLINK-34974
Async aggregating state
|
Jie Pu
|
Zakelly Lan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-35268
|
FLINK-34974
Support TTL for Async State API
|
Yanfei Lei
|
Hangxiang Yu
|
|
Resolved |
Resolved
|
|
|
|
|
|
|
|
FLINK-35186
|
FLINK-34974
Create State V2 from new StateDescriptor
|
Zakelly Lan
|
Zakelly Lan
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-35168
|
FLINK-34974
Basic State Iterator for async processing
|
Zakelly Lan
|
Zakelly Lan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-35153
|
FLINK-34974
Internal Async State Implementation and StateDescriptor for Map/List State
|
Zakelly Lan
|
Zakelly Lan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-35046
|
FLINK-34974
Introduce New KeyedStateBackend related Async interfaces
|
Hangxiang Yu
|
Hangxiang Yu
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-34987
|
FLINK-34974
Introduce Internal State Interface for Async State API
|
Hangxiang Yu
|
Hangxiang Yu
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-34979
|
FLINK-34974
Implement State Future and related utilities
|
Zakelly Lan
|
Zakelly Lan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-34978
|
FLINK-34974
Introduce Asynchronous State APIs
|
Zakelly Lan
|
Zakelly Lan
|
|
Resolved |
Fixed
|
|
|
|
|