Hi! Do you mean that you want to count all elements across all partitions of a DataStream? To do that, you'll need to transform the DataStream with an operator of parallelism 1, e.g.
DatatStream<String> stream = ...; stream.map(new CountingMap<>()).setParallelism(1); Cheers, Gordon -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
