Uses of Class
org.apache.storm.streams.operations.mappers.PairValueMapper

Packages that use PairValueMapper

Package	Description
org.apache.storm.streams

Uses of PairValueMapper in org.apache.storm.streams

Methods in org.apache.storm.streams with parameters of type PairValueMapper

Modifier and Type	Method and Description
<K,V> PairStream<K,V>	StreamBuilder.newStream(IRichSpout spout, PairValueMapper<K,V> pairValueMapper) Creates a new PairStream of key-value pairs from the given IRichSpout by extracting key and value from tuples via the supplied PairValueMapper.
<K,V> PairStream<K,V>	StreamBuilder.newStream(IRichSpout spout, PairValueMapper<K,V> pairValueMapper, int parallelism) Creates a new PairStream of key-value pairs from the given IRichSpout by extracting key and value from tuples via the supplied PairValueMapper and with the given value of parallelism.