org.apache.hadoop.mapred

Interface ShuffleConsumerPlugin<K,V>

All Known Implementing Classes:

Shuffle

@InterfaceAudience.LimitedPrivate(value="mapreduce")
 @InterfaceStability.Unstable
public interface ShuffleConsumerPlugin<K,V>

ShuffleConsumerPlugin for serving Reducers. It may shuffle MOF files from either the built-in ShuffleHandler or from a 3rd party AuxiliaryService.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	ShuffleConsumerPlugin.Context<K,V>

Method Summary

Modifier and Type	Method and Description
void	close()
void	init(ShuffleConsumerPlugin.Context<K,V> context)
RawKeyValueIterator	run()

Method Detail

init

void init(ShuffleConsumerPlugin.Context<K,V> context)

run

RawKeyValueIterator run()
                 throws IOException,
                        InterruptedException

Throws:

IOException

InterruptedException

close

void close()