Thanks for the pointer. Looks like it can be achieved with stateful windowing, but it's just based on skimming so there may be hard parts in detail. I'll spend time to read it and see how we can achieve it. (Both core API and stream API which will be brought to Storm 2.0.0.)
Thanks, Jungtaek Lim (HeartSaVioR) 2017년 12월 22일 (금) 오후 5:08, Jinhua Luo <luajit...@gmail.com>님이 작성: > > https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/stream/operators/windows.html#reducefunction > > https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/stream/operators/windows.html#processwindowfunction-with-incremental-aggregation > > Jstorm also supports incremental aggregation upon the window. > > 2017-12-22 13:31 GMT+08:00 Jungtaek Lim <kabh...@gmail.com>: > > Hi Jinhua, > > > > could you refer the link of doc for Flink? I'm not exactly aware of > > incremental aggregation upon the window, so let me take a look at. > > > > 2017년 12월 21일 (목) 오후 2:09, Jinhua Luo <luajit...@gmail.com>님이 작성: > >> > >> Hi All, > >> > >> The window may buffer many tuples before evaluation, does storm > >> support incremental aggregation upon the window, just like flink does? >
