Uses of Interface
org.apache.storm.streams.operations.PairFunction
-
Packages that use PairFunction Package Description org.apache.storm.sql.runtime.streams.functions org.apache.storm.streams org.apache.storm.streams.operations.mappers -
-
Uses of PairFunction in org.apache.storm.sql.runtime.streams.functions
Classes in org.apache.storm.sql.runtime.streams.functions that implement PairFunction Modifier and Type Class Description class
StreamInsertMapToPairFunction
-
Uses of PairFunction in org.apache.storm.streams
Methods in org.apache.storm.streams with parameters of type PairFunction Modifier and Type Method Description <K,V>
PairStream<K,V>Stream. mapToPair(PairFunction<? super T,? extends K,? extends V> function)
Returns a stream of key-value pairs by applying aPairFunction
on each value of this stream. -
Uses of PairFunction in org.apache.storm.streams.operations.mappers
Classes in org.apache.storm.streams.operations.mappers that implement PairFunction Modifier and Type Class Description class
PairValueMapper<K,V>
Extracts a typed key-value pair from a tuple.
-