org.apache.storm.streams.operations

Interface PairFlatMapFunction<T,K,V>

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