Hi,

After performing a windowAll() on a DataStream[String], is there any method
to collect and return an array with all Strings within a window (similar to
.collect in Spark).

I basically want to ship all strings in a window to a remote server through
a socket, and want to use the same socket connection for all strings that I
send. The method .addSink iterates over all records, but does the provided
function runs on the flink client or on the server?

Thanks.

Reply via email to