MCPcopy Create free account
hub / github.com/apache/storm / shuffle

Method shuffle

storm-client/src/jvm/org/apache/storm/trident/Stream.java:222–224  ·  view source on GitHub ↗

## Repartitioning Operation. Use random round robin algorithm to evenly redistribute tuples across all target partitions.

()

Source from the content-addressed store, hash-verified

220 * <p>Use random round robin algorithm to evenly redistribute tuples across all target partitions.
221 */
222 public Stream shuffle() {
223 return partition(Grouping.shuffle(new NullStruct()));
224 }
225
226 /**
227 * ## Repartitioning Operation.

Callers 7

getConfiguredClientMethod · 0.45
PacemakerClientPoolMethod · 0.45
getTopologyMethod · 0.45
testMultiRepartitionMethod · 0.45
hostAssignableSlotsMethod · 0.45
buildTopologyMethod · 0.45

Calls 2

partitionMethod · 0.95
shuffleMethod · 0.95

Tested by 3

getTopologyMethod · 0.36
testMultiRepartitionMethod · 0.36