Sink data into java stream variable

[Soheil Pourbafrani]

Hi,

In Flink Stream processing can we sink data into java stream array?

[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.html#using-managed-operator-state

On Mon, Apr 15, 2019 at 3:01 PM Soheil Pourbafrani <[hidden email]> wrote:

Hi,

In Flink Stream processing can we sink data into java stream array?