com.aliyun.odps.mapred.local

Class MapOutputBuffer

java.lang.Object

com.aliyun.odps.mapred.local.MapOutputBuffer

Direct Known Subclasses:

TaskOutput

public class MapOutputBuffer
extends Object

Constructor Summary

Constructors

Constructor and Description
MapOutputBuffer(JobConf conf, int reduceNum)
MapOutputBuffer(JobConf conf, Pipeline pipeline, String taskId, int reduceNum)

Method Summary

Modifier and Type	Method and Description
void	add(Record key, Record value)
void	add(Record key, Record value, int partition)
void	add(Record record, String label)
Comparator<? super Object[]>	getComparator()
Queue<Object[]>	getPartitionQueue(int partition)
long	getTotalRecordCount()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MapOutputBuffer

public MapOutputBuffer(JobConf conf,
                       int reduceNum)

MapOutputBuffer

public MapOutputBuffer(JobConf conf,
                       Pipeline pipeline,
                       String taskId,
                       int reduceNum)

Method Detail

add

public void add(Record key,
                Record value)

add

public void add(Record key,
                Record value,
                int partition)

getPartitionQueue

public Queue<Object[]> getPartitionQueue(int partition)

getComparator

public Comparator<? super Object[]> getComparator()

getTotalRecordCount

public long getTotalRecordCount()

add

public void add(Record record,
                String label)