--
You received this message because you are subscribed to the Google Groups "Onyx" group.
To unsubscribe from this group and stop receiving emails from it, send an email to onyx-user+unsubscribe@googlegroups.com.
To post to this group, send email to onyx...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/onyx-user/595ca6f6-14b3-426c-ad7b-d05cbea9b39a%40googlegroups.com.
Onyx's windows different from Spark - they don't chain in succession. Each task has a function, zero or more windows, flow conditions, lifecycles, and so forth. Segment proceed from task to task and have their function applied.If you're looking to have two tasks, A and B, both windowed where B's window contents are populated by A's window contents, you want to use trigger/emit. trigger/emit sends contents of one window to another task. Then in your onyx/fn, you want to return empty vector so that you're original segment doesn't proceed downstream.
On Thu, May 4, 2017 at 3:40 AM, Punit Naik <naik.p...@gmail.com> wrote:
I do realise that I can use the "trigger/sync" functionality but I want to perform more aggregations (more windows) after the first aggregation.
On Thursday, May 4, 2017 at 4:08:41 PM UTC+5:30, Punit Naik wrote:HiI used a "conj" aggregation in a window after "grouping by" on a particular key and passed the result onto another function. The function received the original segments rather than receiving "conjed" list of lists from the first window.How should I do this?
--
You received this message because you are subscribed to the Google Groups "Onyx" group.
To unsubscribe from this group and stop receiving emails from it, send an email to onyx-user+...@googlegroups.com.
To post to this group, send email to onyx...@googlegroups.com.
To unsubscribe from this group and stop receiving emails from it, send an email to onyx-user+unsubscribe@googlegroups.com.
To post to this group, send email to onyx...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/onyx-user/ee62e69c-2ddf-42a7-8903-93f4b93d127f%40googlegroups.com.
All of the windowed examples use triggers in onyx-examples. There's also an example of using trigger/emit in the tests.
On Sun, May 7, 2017 at 11:57 PM, Punit Naik <naik.p...@gmail.com> wrote:
Thanks Michael. Could you please add some examples on triggers though? Especially for trigger/emit?--
On Thursday, May 4, 2017 at 8:11:06 PM UTC+5:30, Mike Drogalis wrote:Onyx's windows different from Spark - they don't chain in succession. Each task has a function, zero or more windows, flow conditions, lifecycles, and so forth. Segment proceed from task to task and have their function applied.If you're looking to have two tasks, A and B, both windowed where B's window contents are populated by A's window contents, you want to use trigger/emit. trigger/emit sends contents of one window to another task. Then in your onyx/fn, you want to return empty vector so that you're original segment doesn't proceed downstream.On Thu, May 4, 2017 at 3:40 AM, Punit Naik <naik.p...@gmail.com> wrote:I do realise that I can use the "trigger/sync" functionality but I want to perform more aggregations (more windows) after the first aggregation.--
On Thursday, May 4, 2017 at 4:08:41 PM UTC+5:30, Punit Naik wrote:HiI used a "conj" aggregation in a window after "grouping by" on a particular key and passed the result onto another function. The function received the original segments rather than receiving "conjed" list of lists from the first window.How should I do this?
You received this message because you are subscribed to the Google Groups "Onyx" group.
To unsubscribe from this group and stop receiving emails from it, send an email to onyx-user+...@googlegroups.com.
To post to this group, send email to onyx...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/onyx-user/595ca6f6-14b3-426c-ad7b-d05cbea9b39a%40googlegroups.com.
You received this message because you are subscribed to the Google Groups "Onyx" group.
To unsubscribe from this group and stop receiving emails from it, send an email to onyx-user+...@googlegroups.com.
To post to this group, send email to onyx...@googlegroups.com.
To unsubscribe from this group and stop receiving emails from it, send an email to onyx-user+unsubscribe@googlegroups.com.
To post to this group, send email to onyx...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/onyx-user/a4241082-f247-41c4-8d01-d7771e6e9e97%40googlegroups.com.