Hi Saiph, you can use AllWindowFunction via .apply(...) to get an .collect method:
From: https://ci.apache.org/projects/flink/flink-docs-release-0.10/apis/streaming_guide.html > // applying an AllWindowFunction on non-keyed window stream > allWindowedStream.apply (new AllWindowFunction<Tuple2<String,Integer>, > Integer, Window>() { > public void apply (Window window, > Iterable<Tuple2<String, Integer>> values, > Collector<Integer> out) throws Exception { > int sum = 0; > for (value t: values) { > sum += t.f1; > } > out.collect (new Integer(sum)); > } > }); If you consume all those value via an sink, the sink will run an the cluster. You can use .writeToSocket(...) as sink: https://ci.apache.org/projects/flink/flink-docs-release-0.10/apis/streaming_guide.html#data-sinks -Matthias On 01/18/2016 06:30 PM, Saiph Kappa wrote: > 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.
signature.asc
Description: OpenPGP digital signature
