August 2017
Beginner to intermediate
284 pages
6h 51m
English
The broadcast operation is a special repartitioning operation that does not partition the tuples, but replicates them to all partitions. Here is a diagram that shows how the tuples are sent over the network:

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