Is it possible/advisable to have a trigger based on window state?
You mean decide whether to trigger based on what is in the window state?
Yes
If so, yes, that’s perfectly fine. You can set :window-state
in http://www.onyxplatform.org/docs/cheat-sheet/latest/#trigger-entry/:trigger/state-context. That way Onyx will not maintain trigger state.
Nice!
I take it in that case you only need :trigger/trigger-fire?
in the trigger definition.
IIRC, yes.
Does onyx-local rt support water mark functionality? e.g
:onyx/assign-watermark-fn ::watermark-fn
:trigger/on :onyx.triggers/watermark
:trigger/state-context [:window-state]
Can an aggregation task happen on multiple peers?
@drewverlee should do, though it’s possible we don’t support window-state triggers yet. I think we do though.
@dbernal yes. You will end up with hash-routing on the group-by key, and if you have say 10 peers, you will always end up with the same group key on the same peer slot.
onyx-plugin template 0.12.7.1 is out https://github.com/onyx-platform/onyx-plugin, thanks to the hard work of Joaquim Torres on our gitter.
It’s a really big deal as it had not been updated for the new plugin model yet.