Uses of Class
org.apache.storm.streams.operations.mappers.PairValueMapper
-
Uses of PairValueMapper in org.apache.storm.streams
Modifier and TypeMethodDescription<K,
V> PairStream<K, V> StreamBuilder.newStream
(IRichSpout spout, PairValueMapper<K, V> pairValueMapper) Creates a newPairStream
of key-value pairs from the givenIRichSpout
by extracting key and value from tuples via the suppliedPairValueMapper
.<K,
V> PairStream<K, V> StreamBuilder.newStream
(IRichSpout spout, PairValueMapper<K, V> pairValueMapper, int parallelism) Creates a newPairStream
of key-value pairs from the givenIRichSpout
by extracting key and value from tuples via the suppliedPairValueMapper
and with the given value of parallelism.