nt, and I'm not sure if there might be other
issues with it I'm not seeing - it definitely doesn't _feel_ like a great
solution.
Any thoughts?
On Tue, Aug 23, 2016 at 11:53 AM, Michael Warnock
wrote:
> Thanks for the quick response!
>
> I've been wondering about C
> Sharing state across successive nodes does not work, because the functions
> could be executed on different machines and one would need to do remote and
> synchronized state updates that way.
>
> Do you think you can use the CoMap / CoFlatMap functions for this?
>
> Greetings,
I'm trying to do something that seems like it should be possible, but my
implementation doesn't behave as expected, and I'm not sure how else to
express it.
Let's say the stream is composed of tuples like this: (Alice, Bob, 1) and I
want to keyBy(1), flatMap with state associated with Alice, then
