Package stroom.mapreduce.v2
Interface Source<K,V>
-
- All Superinterfaces:
java.lang.Iterable<Pair<K,V>>
- All Known Subinterfaces:
PairQueue<K,V>
- All Known Implementing Classes:
BlockingPairQueue
,UnsafePairQueue
public interface Source<K,V> extends java.lang.Iterable<Pair<K,V>>