Package stroom.mapreduce.v2

Interface PairQueue<K,V>

All Superinterfaces:

java.lang.Iterable<Pair<K,V>>, OutputCollector<K,V>, java.io.Serializable, Source<K,V>

All Known Implementing Classes:

BlockingPairQueue, UnsafePairQueue

public interface PairQueue<K,V>
extends OutputCollector<K,V>, Source<K,V>, java.io.Serializable

Method Summary

Methods inherited from interface java.lang.Iterable

forEach, iterator, spliterator

Methods inherited from interface stroom.mapreduce.v2.OutputCollector

collect