August 2017
Beginner to intermediate
284 pages
6h 51m
English
The Aggregator first runs the global repartitioning operation on the input stream to combine all the partitions of the same batch into a single partition, and then runs the aggregation function on each batch. By definition, the Aggregator looks very similar to the ReduceAggregator. The BaseAggregator<State> contains the following methods:
Read now
Unlock full access