September 2017
Beginner to intermediate
360 pages
8h 13m
English
Each batch of the tuple is aggregated in isolation. In aggregates the process, initially tuples are repartitioned using global grouping. We will discuss grouping in the next section in detail:
stream.aggregate(new Count(), new Fields("count"))
The preceding statement will give the count of a batch.
Read now
Unlock full access