org.apache.hadoop.mapreduce.task.reduce

Class Shuffle<K,V>

java.lang.Object

org.apache.hadoop.mapreduce.task.reduce.Shuffle<K,V>

All Implemented Interfaces:

ShuffleConsumerPlugin<K,V>, ExceptionReporter

@InterfaceAudience.LimitedPrivate(value="MapReduce")
@InterfaceStability.Unstable
public class Shuffle<K,V>
extends Object
implements ShuffleConsumerPlugin<K,V>, ExceptionReporter

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Shuffle.ShuffleError

Nested classes/interfaces inherited from interface org.apache.hadoop.mapred.ShuffleConsumerPlugin

ShuffleConsumerPlugin.Context<K,V>

Constructor Summary

Constructors

Constructor and Description
Shuffle()

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
protected MergeManager<K,V>	createMergeManager(ShuffleConsumerPlugin.Context context)
void	init(ShuffleConsumerPlugin.Context context)
void	reportException(Throwable t)
RawKeyValueIterator	run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Shuffle

public Shuffle()

Method Detail

init

public void init(ShuffleConsumerPlugin.Context context)

Specified by:

init in interface ShuffleConsumerPlugin<K,V>

createMergeManager

protected MergeManager<K,V> createMergeManager(ShuffleConsumerPlugin.Context context)

run

public RawKeyValueIterator run()
                        throws IOException,
                               InterruptedException

Specified by:

run in interface ShuffleConsumerPlugin<K,V>

Throws:

IOException

InterruptedException

close

public void close()

Specified by:

close in interface ShuffleConsumerPlugin<K,V>

reportException

public void reportException(Throwable t)

Specified by:

reportException in interface ExceptionReporter