Re: Sink data into java stream variable

2019-04-15 Thread Oytun Tez
Hi Soheil, This is a tricky question that requires much more context due to distributed nature of Flink. Take a look at [1], especially BufferingSink example which I will *assume* behaves similar to your need. Oytun [1] https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/state/state

Sink data into java stream variable

2019-04-15 Thread Soheil Pourbafrani
Hi, In Flink Stream processing can we sink data into java stream array?