On Tue, Aug 2, 2016 at 4:37 PM, amir bahmanyari <[email protected]> wrote:
> .apply(new CountWords()) > // counts same word occurence and return it as a long > That is an aggregation. > // Format the long result created by CountWords object to text > .apply(MapElements.via(new FormatAsTextFn())) > This is not. > // TextIO to write result as text into an output-file set in options >
