org.apache.tez.runtime.library.common.combine
Interface Combiner

@InterfaceStability.Unstable
@InterfaceAudience.LimitedPrivate(value="mapreduce")
public interface Combiner

Combiner Initialization

The Combiner class is picked up using the TEZ_RUNTIME_COMBINER_CLASS attribute in TezJobConfig Partitioners need to provide a single argument (TezRawKeyValueIterator) constructor.

Method Summary

void	combine(TezRawKeyValueIterator rawIter, IFile.Writer writer)

Method Detail

combine

void combine(TezRawKeyValueIterator rawIter,
             IFile.Writer writer)
             throws InterruptedException,
                    IOException

Throws:

InterruptedException

IOException