|
|
|
FLINK-19640
|
FLINK-19268
Expose to users the batch-style execution for bounded keyed streams
|
Dawid Wysakowicz
|
Dawid Wysakowicz
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-19475
|
FLINK-19268
Implement a timer service that holds a single key at a time
|
Dawid Wysakowicz
|
Dawid Wysakowicz
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-19474
|
FLINK-19268
Implement a state backend that holds a single key at a time
|
Dawid Wysakowicz
|
Dawid Wysakowicz
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-19473
|
FLINK-19268
Implement multi inputs sorting DataInput
|
Dawid Wysakowicz
|
Dawid Wysakowicz
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-19472
|
FLINK-19268
Implement one input sorting DataInput
|
Dawid Wysakowicz
|
Dawid Wysakowicz
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19288
|
FLINK-19268
Make InternalTimeServiceManager an interface
|
Dawid Wysakowicz
|
Dawid Wysakowicz
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19270
|
FLINK-19268
Extract an inteface from AbstractKeyedStateBackend
|
Dawid Wysakowicz
|
Dawid Wysakowicz
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19269
|
FLINK-19268
Make the PushingAsyncDataInput.DataOutput aware of endOfInput
|
Dawid Wysakowicz
|
Dawid Wysakowicz
|
|
Closed |
Won't Do
|
|
|
|
|
|
|
|
FLINK-19165
|
FLINK-19268
Clean up the UnilateralSortMerger
|
Dawid Wysakowicz
|
Dawid Wysakowicz
|
|
Closed |
Fixed
|
|
|
|
|