@InterfaceAudience.LimitedPrivate(value="MapReduce")
@InterfaceStability.Unstable
public interface ShuffleConsumerPlugin
Modifier and Type | Interface and Description |
---|---|
static class |
ShuffleConsumerPlugin.Context |
Modifier and Type | Method and Description |
---|---|
void |
close()
close and clean any resource associated with this object.
|
RawKeyValueIterator |
createKVIterator()
To create a key-value iterator to read the merged output.
|
boolean |
fetchOutputs()
To fetch the map outputs.
|
java.lang.Throwable |
getMergeThrowable()
To get any exception from merge.
|
void |
init(ShuffleConsumerPlugin.Context context)
To initialize the reduce copier plugin.
|
void init(ShuffleConsumerPlugin.Context context) throws java.lang.ClassNotFoundException, java.io.IOException
context
- reduce copier context.java.lang.ClassNotFoundException
java.io.IOException
boolean fetchOutputs() throws java.io.IOException
java.io.IOException
RawKeyValueIterator createKVIterator() throws java.io.IOException
java.io.IOException
void close()
java.lang.Throwable getMergeThrowable()
Copyright © 2009 The Apache Software Foundation