@InterfaceAudience.LimitedPrivate(value="MapReduce") @InterfaceStability.Unstable public static class MapTask.MapOutputBuffer<K,V> extends java.lang.Object implements MapOutputCollector<K,V>, org.apache.hadoop.util.IndexedSortable
Modifier and Type | Class and Description |
---|---|
protected class |
MapTask.MapOutputBuffer.BlockingBuffer
Inner class managing the spill of serialized records to disk.
|
class |
MapTask.MapOutputBuffer.Buffer |
protected class |
MapTask.MapOutputBuffer.InMemValBytes
Inner class wrapping valuebytes, used for appendRaw.
|
protected class |
MapTask.MapOutputBuffer.MRResultIterator |
protected class |
MapTask.MapOutputBuffer.SpillThread |
MapOutputCollector.Context
Constructor and Description |
---|
MapTask.MapOutputBuffer() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
collect(K key,
V value,
int partition) |
int |
compare(int i,
int j)
Compare logical range, st i, j MOD offset capacity.
|
void |
flush() |
void |
init(MapOutputCollector.Context context) |
void |
swap(int i,
int j)
Swap logical indices st i, j MOD offset capacity.
|
public void init(MapOutputCollector.Context context) throws java.io.IOException, java.lang.ClassNotFoundException
init
in interface MapOutputCollector<K,V>
java.io.IOException
java.lang.ClassNotFoundException
public void collect(K key, V value, int partition) throws java.io.IOException
collect
in interface MapOutputCollector<K,V>
java.io.IOException
public int compare(int i, int j)
compare
in interface org.apache.hadoop.util.IndexedSortable
IndexedSortable.compare(int, int)
public void swap(int i, int j)
swap
in interface org.apache.hadoop.util.IndexedSortable
IndexedSortable.swap(int, int)
public void flush() throws java.io.IOException, java.lang.ClassNotFoundException, java.lang.InterruptedException
flush
in interface MapOutputCollector<K,V>
java.io.IOException
java.lang.ClassNotFoundException
java.lang.InterruptedException
public void close()
close
in interface MapOutputCollector<K,V>
Copyright © 2009 The Apache Software Foundation