August 2017
Beginner to intermediate
284 pages
6h 51m
English
This repartitioning operation routes all the tuples to the same partition. Hence, the same target partition is selected for all the batches in the stream. Here is a diagram that shows how the tuples are repartitioned using the global operation:

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