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

Method partitionBy

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

## Repartitioning Operation.

(Fields fields)

Source from the content-addressed store, hash-verified

190 * ## Repartitioning Operation.
191 */
192 public Stream partitionBy(Fields fields) {
193 projectionValidation(fields);
194 return partition(Grouping.fields(fields.toList()));
195 }
196
197 /**
198 * ## Repartitioning Operation.

Callers 6

testStreamProjectionValidationMethod · 0.95
buildTopologyMethod · 0.45
multiReduceMethod · 0.45
persistentAggregateMethod · 0.45
stateQueryMethod · 0.45
aggPartitionMethod · 0.45

Calls 4

projectionValidationMethod · 0.95
partitionMethod · 0.95
fieldsMethod · 0.95
toListMethod · 0.45

Tested by 2

testStreamProjectionValidationMethod · 0.76
buildTopologyMethod · 0.36