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 Description <K,V>
PairStream<K,V>StreamBuilder. newStream(IRichSpout spout, PairValueMapper<K,V> pairValueMapper)Creates a newPairStreamof key-value pairs from the givenIRichSpoutby 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 newPairStreamof key-value pairs from the givenIRichSpoutby extracting key and value from tuples via the suppliedPairValueMapperand with the given value of parallelism.
-