Interface PairFlatMapFunction<T,K,V>

Type Parameters:
T - the type of the input to the function
K - the key type of the key-value pairs produced as a result
V - the value type of the key-value pairs produced as a result
All Superinterfaces:
FlatMapFunction<T,Pair<K,V>>, Function<T,Iterable<Pair<K,V>>>, Operation, Serializable

public interface PairFlatMapFunction<T,K,V> extends FlatMapFunction<T,Pair<K,V>>
A function that accepts one argument and returns an Iterable of Pair as its result.
  • Method Summary

    Methods inherited from interface org.apache.storm.streams.operations.Function

    apply