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

Method broadcast

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

## Repartitioning Operation. Every tuple is replicated to all target partitions. This can useful during DRPC – for example, if you need to do a stateQuery on every partition of data.

()

Source from the content-addressed store, hash-verified

261 * every partition of data.
262 */
263 public Stream broadcast() {
264 return partition(Grouping.all(new NullStruct()));
265 }
266
267 /**
268 * ## Repartitioning Operation.

Callers 1

Calls 2

partitionMethod · 0.95
allMethod · 0.95

Tested by 1