DirectInMemoryOutput(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.mapreduce.TaskAttemptID mapId,
DirectShuffleMergeManagerImpl<K,V> merger,
int size,
org.apache.hadoop.io.compress.CompressionCodec codec,
boolean primaryMapOutput) |
DirectInMemoryReader(DirectShuffleMergeManagerImpl<K,V> merger,
org.apache.hadoop.mapreduce.TaskAttemptID taskAttemptId,
byte[] data,
int start,
int length,
org.apache.hadoop.conf.Configuration conf) |
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) |