August 2017
Beginner to intermediate
284 pages
6h 51m
English
This repartitioning operation sends all the tuples belonging to one batch into the same partition. The other batches of the same stream may go to a different partition. As the name suggests, this repartition is global at the batch level. Here is a diagram that shows how the tuples are repartitioned using the batchGlobal operation:

Here is a piece of code that shows how we can use the batchGlobal operation:
mystream.batchGlobal().each(new Fields("a","b"), new myFilter()).parallelismHint(2)
Read now
Unlock full access