...
An aggregator plugin will operate over windows in the stream, and can be implemented by a call to flatMapToPair(), then reduceByKey().
...
ReduceFunction
A reducer reduce function plugin will reduce all the records in a window into a single record.
...