Hello, I am using GlobalWindow and my custom trigger (similar to ContinuousProcessingTimeTrigger). In my trigger I want to control the TriggerResult based on external datasource. That datasource has flags for each key which describes if stream for that key has been finished (so, can be purged).
I am thinking of two approaches, so could you give me some advise about which is better, or are there any other better solutions? 1. Check datasource in onProcessingTime() Query datasource (i.e. Redis) in onProcessingTime() and return FIRE or FIRE_AND_PURGE based on the result. Maybe I will create Jedis or JedisPool instance in the trigger's constructor? 2. External program periodically query datasource and send special event for keys of finished stream. The schema of the event will be the same as normal events in the stream, but has special value in a field. So, the trigger will be able to handle the event in onElement(). I need to filter that event afterward so that it does not affect the computation result. Thanks, Hironori Ogibayashi
