public class DirectOnDiskMapOutput<K,V>
extends org.apache.hadoop.mapreduce.task.reduce.MapOutput<K,V>
Constructor and Description |
---|
DirectOnDiskMapOutput(org.apache.hadoop.mapreduce.TaskAttemptID mapId,
org.apache.hadoop.mapreduce.TaskAttemptID reduceId,
DirectShuffleMergeManagerImpl<K,V> merger,
long size,
org.apache.hadoop.mapred.JobConf conf,
org.apache.hadoop.mapred.MapOutputFile mapOutputFile,
int fetcher,
boolean primaryMapOutput) |
Modifier and Type | Method and Description |
---|---|
void |
abort() |
void |
commit() |
String |
getDescription() |
void |
shuffle(org.apache.hadoop.mapreduce.task.reduce.MapHost host,
InputStream input,
long mapOutputLength,
long decompressedLength,
org.apache.hadoop.mapreduce.task.reduce.ShuffleClientMetrics metrics,
org.apache.hadoop.mapred.Reporter reporter) |
public DirectOnDiskMapOutput(org.apache.hadoop.mapreduce.TaskAttemptID mapId, org.apache.hadoop.mapreduce.TaskAttemptID reduceId, DirectShuffleMergeManagerImpl<K,V> merger, long size, org.apache.hadoop.mapred.JobConf conf, org.apache.hadoop.mapred.MapOutputFile mapOutputFile, int fetcher, boolean primaryMapOutput) throws IOException
IOException
public void shuffle(org.apache.hadoop.mapreduce.task.reduce.MapHost host, InputStream input, long mapOutputLength, long decompressedLength, org.apache.hadoop.mapreduce.task.reduce.ShuffleClientMetrics metrics, org.apache.hadoop.mapred.Reporter reporter) throws IOException
shuffle
in class org.apache.hadoop.mapreduce.task.reduce.MapOutput<K,V>
IOException
public void commit() throws IOException
commit
in class org.apache.hadoop.mapreduce.task.reduce.MapOutput<K,V>
IOException
public void abort()
Copyright © 2019 Apache Software Foundation. All Rights Reserved.