Re: MessageCollector and WindowableTask

2018-06-05 Thread Jagadish Venkatraman
; Software Engineer > www.helixeducation.com > Blog | Twitter | Facebook | LinkedIn > > > From: Jagadish Venkatraman > Sent: Tuesday, June 5, 2018 10:22 AM > To: dev@samza.apache.org > Subject: Re: MessageCollector and WindowableTask > > Hey Jeremiah, > > >&g

Re: MessageCollector and WindowableTask

2018-06-05 Thread Jeremiah Adams
0:22 AM To: dev@samza.apache.org Subject: Re: MessageCollector and WindowableTask Hey Jeremiah, >> Please only use that MessageCollector object for sending messages, and don't use it outside of the call to window(). Why MessageCollector should not be used outside the call to window()

Re: MessageCollector and WindowableTask

2018-06-05 Thread Jagadish Venkatraman
Hey Jeremiah, >> Please only use that MessageCollector object for sending messages, and don't use it outside of the call to window(). Why MessageCollector should not be used outside the call to window() in a WindowableTask? The collector and coordinator instances are expected to be used within a

MessageCollector and WindowableTask

2018-06-05 Thread Jeremiah Adams
>From th?e docs: "If you need to send messages to output streams, you can use the MessageCollector object passed to the window() method. Please only use that MessageCollector object for s