|
|
|
FLINK-2891
|
FLINK-2674
Key for Keyed State is not set upon Window Evaluation
|
Aljoscha Krettek
|
Aljoscha Krettek
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-2870
|
FLINK-2674
Add support for accumulating/discarding for Event-Time Windows
|
Aljoscha Krettek
|
Aljoscha Krettek
|
|
Closed |
Duplicate
|
|
|
|
|
|
|
|
FLINK-2864
|
FLINK-2674
Make State of General-Purpose Window Operators Fault-Tolerant
|
Aljoscha Krettek
|
Aljoscha Krettek
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-2830
|
FLINK-2674
Add Fold Window Operation for new Windowing API
|
Aljoscha Krettek
|
Aljoscha Krettek
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-2819
|
FLINK-2674
Add Windowed Join/CoGroup Operator Based on Tagged Union
|
Aljoscha Krettek
|
Aljoscha Krettek
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-2807
|
FLINK-2674
Add javadocs/comments to new windowing mechanics
|
Aljoscha Krettek
|
Gyula Fora
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-2780
|
FLINK-2674
Remove Old Windowing Logic and API
|
Aljoscha Krettek
|
Aljoscha Krettek
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-2779
|
FLINK-2674
Update documentation to reflect new Stream/Window API
|
Kostas Tzoumas
|
Aljoscha Krettek
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-2778
|
FLINK-2674
Add API for non-parallel non-keyed Windows
|
Aljoscha Krettek
|
Aljoscha Krettek
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-2753
|
FLINK-2674
Add new window API to streaming API
|
Aljoscha Krettek
|
Stephan Ewen
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-2683
|
FLINK-2674
Add utilities for heap-backed keyed state in time panes
|
Stephan Ewen
|
Stephan Ewen
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-2682
|
FLINK-2674
Add a dedicated processing time aligned keyed window operator
|
Stephan Ewen
|
Stephan Ewen
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-2680
|
FLINK-2674
Create a dedicated aligned-event time window operator
|
Stephan Ewen
|
Stephan Ewen
|
|
Closed |
Won't Fix
|
|
|
|
|
|
|
|
FLINK-2677
|
FLINK-2674
Add a general-purpose keyed-window operator
|
Aljoscha Krettek
|
Stephan Ewen
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-2676
|
FLINK-2674
Add abstraction for keyed window state
|
Stephan Ewen
|
Stephan Ewen
|
|
Closed |
Won't Fix
|
|
|
|
|
|
|
|
FLINK-2675
|
FLINK-2674
Add utilities for scheduled triggers
|
Stephan Ewen
|
Stephan Ewen
|
|
Closed |
Done
|
|
|
|
|
|
|
|
FLINK-2550
|
FLINK-2674
Rework DataStream API
|
Aljoscha Krettek
|
Aljoscha Krettek
|
|
Closed |
Fixed
|
|
|
|
|