|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use MapOutput | |
---|---|
org.apache.hadoop.mapreduce.task.reduce |
Uses of MapOutput in org.apache.hadoop.mapreduce.task.reduce |
---|
Methods in org.apache.hadoop.mapreduce.task.reduce that return MapOutput | |
---|---|
MapOutput<K,V> |
MergeManagerImpl.reserve(TaskAttemptID mapId,
long requestedSize,
int fetcher)
|
MapOutput<K,V> |
MergeManager.reserve(TaskAttemptID mapId,
long requestedSize,
int fetcher)
To reserve resources for data to be shuffled. |
Methods in org.apache.hadoop.mapreduce.task.reduce with parameters of type MapOutput | |
---|---|
int |
MapOutput.MapOutputComparator.compare(MapOutput<K,V> o1,
MapOutput<K,V> o2)
|
int |
MapOutput.MapOutputComparator.compare(MapOutput<K,V> o1,
MapOutput<K,V> o2)
|
void |
ShuffleSchedulerImpl.copySucceeded(TaskAttemptID mapId,
MapHost host,
long bytes,
long millis,
MapOutput<K,V> output)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |