Package | Description |
---|---|
org.apache.hadoop.mapreduce.task.reduce |
Modifier and Type | Method and Description |
---|---|
MapOutputLocation |
DirectShuffleFetcher.getLocation()
Get the current map output location.
|
MapOutputLocation |
DirectShuffleSchedulerImpl.getLocation() |
Modifier and Type | Method and Description |
---|---|
void |
DirectShuffleSchedulerImpl.copyFailed(org.apache.hadoop.mapreduce.TaskAttemptID mapId,
MapOutputLocation loc) |
protected long |
DirectShuffleFetcher.copyOutput(MapOutputLocation loc)
Copies a a map output from a remote host.
|
void |
DirectShuffleSchedulerImpl.copySucceeded(org.apache.hadoop.mapreduce.TaskAttemptID mapId,
MapOutputLocation loc,
long bytes,
long millis,
org.apache.hadoop.mapreduce.task.reduce.MapOutput<K,V> output) |
Copyright © 2018 Apache Software Foundation. All Rights Reserved.