Uses of Class
org.apache.storm.streams.operations.mappers.PairValueMapper
Packages that use PairValueMapper
-
Uses of PairValueMapper in org.apache.storm.streams
Methods in org.apache.storm.streams with parameters of type PairValueMapperModifier and TypeMethodDescription<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.