Re: can operators emit on a different from the operator itself thread?

Should be have this as an utility ? Thks Amol On Wed, Aug 10, 2016 at 1:57 PM, Munagala Ramanath wrote: > For cases where use of a different thread is needed, it can write tuples > to a queue from where the operator thread pulls them -- > JdbcPollInputOperator in Malhar

Re: can operators emit on a different from the operator itself thread?

For cases where use of a different thread is needed, it can write tuples to a queue from where the operator thread pulls them -- JdbcPollInputOperator in Malhar has an example. Ram On Wed, Aug 10, 2016 at 1:50 PM, hsy...@gmail.com wrote: > Hey Vlad, > > Thanks for bringing

Re: can operators emit on a different from the operator itself thread?

Hey Vlad, Thanks for bringing this up. Is there an easy way to detect unexpected use of emit method without hurt the performance. Or at least if we can detect this in debug mode. Regards, Siyuan On Wed, Aug 10, 2016 at 11:27 AM, Vlad Rozov wrote: > The short answer is