Re: Dataset using several count operator in the same environment

Hi Ebru, the count() operator is a very simple utility functions that calls execute() internally. If you want to have a more complex pipeline you can take a look at how our WordCount [0] example works. The general concept is to emit a 1 for every record and sum the ones in parallel. If you ne

Dataset using several count operator in the same environment

Hi all, We are trying to use more than one count operator for dataset, but it executes first count and skips other operations. Also we call env.execute(). How can we solve this problem? -Ebru