case classPreferLocalDependency(get: Boolean) extends Product with Serializable
This signals that the storm bolts should use localOrShuffleGrouping, which means that if the downstream bolt
has a task on the same local worker, the output will only go to those tasks. Otherwise, shuffling
happens normally. This is important to understand as this can create hot spots in the topology.
This signals that the storm bolts should use localOrShuffleGrouping, which means that if the downstream bolt has a task on the same local worker, the output will only go to those tasks. Otherwise, shuffling happens normally. This is important to understand as this can create hot spots in the topology.