August 2017
Beginner to intermediate
284 pages
6h 51m
English
The Trident aggregator is used to perform the aggregation operation on the input batch, partition, or input stream. For example, if a user wants to count the number of tuples present in each batch, then we can use the count aggregator to count the number of tuples in each batch. The output of the aggregator completely replaces the value of the input tuple. There are three types of aggregator available in Trident:
Let's understand each type of aggregator in detail.
Read now
Unlock full access