Nope, not right now but this is pretty much what we're trying to solve with
side inputs:
https://docs.google.com/document/d/1hIgxi2Zchww_5fWUHLoYiXwSBXjv-M5eOv-MKQYN3m4/edit
On Mon, 21 Nov 2016 at 16:11 Theodore Vasiloudis <
theodoros.vasilou...@gmail.com> wrote:
> Thanks for the clarification Gy
Thanks for the clarification Gyula!
In that case, is it possible currently to make one of the two connected
streams stall until the other stream has produced at least one output
before it starts producing as well?
On Mon, Nov 21, 2016 at 3:16 PM, Gyula Fóra wrote:
> Hi :)
>
> The execution of
Hi :)
The execution of the Connected functions (map1/map2 in this case) are not
affected by the timestamps. In other words it is pretty much arbitrary
which input arrives at the CoMapFunction first.
So I think you did everything correctly.
Gyula
Theodore Vasiloudis ezt írta (időpont:
2016. nov
Hello all,
I was playing around with the the IncrementalLearningSkeleton example and I
had a couple of questions regarding the behavior of connected streams.
In the example the elements are assigned timestamps, and there is a stream,
model, that produces
Double[] elements by ingesting and process
