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