Hi Garvit,
If you don't mind to take a look at the source code, I would suggest you to
have a look at the "StreamTwoInputProcessor#processInput()" in
StreamTwoInputProcessor.java. Your customer function will be called via here,
the "CoFlatMapFunction#flatMap1()" will be called via
streamOpera
Hi Sihua,
Thanks for the quick response.
Could you please let me know, where can I find more details about it.
Thanks,
On Fri, May 25, 2018 at 11:04 AM, sihua zhou wrote:
> Hi Garvit,
>
> I think you don't need to lock it, they are executed in the same thread
> sync.
>
> Best, Sihua
>
>
>
>
Hi Garvit,
I think you don't need to lock it, they are executed in the same thread sync.
Best, Sihua
在2018年05月25日 10:26，Garvit Sharma 写道：
Hi,
Let's consider, I have two keyed streams one for rules and another for data and
I have created a connected stream.
I am maintaining a managed keyed
