Re: Partial aggregation result sink

[Chirag Dewan]

 Hi LiYue,
This should help : Apache Flink 1.5-SNAPSHOT Documentation: Windows

| 
| 
|  | 
Apache Flink 1.5-SNAPSHOT Documentation: Windows


 |

 |

 |




So basically you need to register a processing time trigger at every 10 minutes 
and on callback, you can FIRE the window result like this:
  @Override    public TriggerResult onProcessingTime(long time, TimeWindow 
window, TriggerContext ctx) throws Exception {      // schedule next timer      
ctx.registerProcessingTimeTimer(System.currentTimeMillis() + 1000L);      
return TriggerResult.FIRE;    }

I hope it helps.
Chirag
    On Monday, 12 March, 2018, 2:10:25 PM IST, 李玥 <liyue2...@gmail.com> wrote:  
 
 Hi,team
    I’m working on a event-time based aggregation application with flink SQL.  
Is there any way to keep sinking partial aggregation result BEFORE time window 
closed?
For example, My SQL:
    select …
    from my_table
    GROUP BY TUMBLE(`timestamp`, INTERVAL '1’ DAY),other_column;
Usually, Flink sink agg result after time-window closed, Is there any way to 
keep sinking TODAY’s partial aggregation result every 10 miniutes so we can see 
today’s performance on my chart.

Thanks!
LiYue