Hi,
I'm afraid the only way to do it right now is using the wrapper that can
contain both, as you suggested.
Cheers,
Aljoscha
On Thu, 30 Jun 2016 at 16:50 Martin Neumann wrote:
> Hej,
>
> I'm currently playing around with some machine learning algorithms in
> Flink streaming.
>
> I have an inpu
Hej,
I'm currently playing around with some machine learning algorithms in Flink
streaming.
I have an input stream that I partition by key and then do a map on each of
the keys, feeding a model and producing a prediction output. Periodically
each operator needs to send model updates to all other
