|
|
|
FLINK-34313
|
FLINK-19604
Update doc about session window tvf
|
xuyang
|
xuyang
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-34100
|
FLINK-19604
Support session window table function without pulling up with window agg
|
xuyang
|
xuyang
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-34049
|
FLINK-19604
Refactor classes related to window TVF aggregation to prepare for non-aligned windows
|
xuyang
|
xuyang
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-34048
|
FLINK-19604
Support session window agg in table runtime instead of using legacy group window agg op
|
xuyang
|
xuyang
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-23565
|
FLINK-19604
Window TVF Supports session window in runtime
|
Jing Zhang
|
Jing Zhang
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-23544
|
FLINK-19604
Window TVF Supports session window
|
Jing Zhang
|
Jing Zhang
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-23023
|
FLINK-19604
Support offset in window TVF
|
Jing Zhang
|
Jing Zhang
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-22715
|
FLINK-19604
Implement streaming window assigner tablefunction operator
|
Jing Zhang
|
Jing Zhang
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-22714
|
FLINK-19604
Simplify `StreamPhysicalWindowTableFunction` to a simple window assigner if successor node with `WindowAttachedWindowingStrategy` in planner
|
Jing Zhang
|
Jing Zhang
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-22159
|
FLINK-19604
Add documentation for the new window TVF based operations
|
Jark Wu
|
Jark Wu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-22099
|
FLINK-19604
Fix bug for semi/anti window join.
|
Jing Zhang
|
Jing Zhang
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-22098
|
FLINK-19604
Fix bug for window join: plan is wrong if join condition contain 'IS NOT DISTINCT FROM'
|
Jing Zhang
|
Jing Zhang
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-22011
|
FLINK-19604
Support local global optimization for window aggregation in runtime
|
Jark Wu
|
Jark Wu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-21881
|
FLINK-19604
Support local global optimization for window aggregation in plan
|
Jark Wu
|
Jark Wu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-21482
|
FLINK-19604
Support grouping set syntax for Window TVF based aggregation
|
Jing Zhang
|
Jing Zhang
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-21305
|
FLINK-19604
Fix Cumulative and Hopping window should accumulate late events belonging to the cleaned slice
|
Jark Wu
|
Jark Wu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-21304
|
FLINK-19604
Support split distinct aggregate for window TVF based aggregate
|
Jark Wu
|
Jark Wu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-21290
|
FLINK-19604
Support Projection push down for Window TVF
|
Jing Zhang
|
Jark Wu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-21054
|
FLINK-19604
Implement mini-batch optimized slicing window aggregate operator
|
Jark Wu
|
Jark Wu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-20877
|
FLINK-19604
Refactor BytesHashMap and BytesMultiMap to support window key
|
Jark Wu
|
Jark Wu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-20860
|
FLINK-19604
Allow streaming operators to use managed memory
|
Xintong Song
|
Jark Wu
|
|
Closed |
Done
|
|
|
|
|
|
|
|
FLINK-20854
|
FLINK-19604
Introduce BytesMultiMap to support buffering records
|
Jark Wu
|
Jark Wu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-20831
|
FLINK-19604
Introduce the in memory topN buffer
|
Unassigned
|
Shengkai Fang
|
|
Closed |
Invalid
|
|
|
|
|
|
|
|
FLINK-19612
|
FLINK-19604
Support CUMULATE window table function in planner
|
Jark Wu
|
Jark Wu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19611
|
FLINK-19604
Introduce WindowProperties MetadataHandler to propagate window properties
|
Jark Wu
|
Jark Wu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19610
|
FLINK-19604
Support streaming window TopN in planner
|
Jing Zhang
|
Jark Wu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19609
|
FLINK-19604
Support streaming window join in planner
|
Jing Zhang
|
Jark Wu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19608
|
FLINK-19604
Support window TVF based window aggreagte in planner
|
Jark Wu
|
Jark Wu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19607
|
FLINK-19604
Implement streaming window TopN operator
|
Jing Zhang
|
Jark Wu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19606
|
FLINK-19604
Implement streaming window join operator
|
Jing Zhang
|
Jark Wu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19605
|
FLINK-19604
Implement cumulative windowing for window aggregate operator
|
Jark Wu
|
Jark Wu
|
|
Closed |
Fixed
|
|
|
|
|