com.aliyun.odps.mapred.local

Class LocalGroupingRecordIterator

java.lang.Object

com.aliyun.odps.mapred.local.LocalGroupingRecordIterator

All Implemented Interfaces:

Iterator<Record>

public class LocalGroupingRecordIterator
extends Object
implements Iterator<Record>

Constructor Summary

Constructors

Constructor and Description
LocalGroupingRecordIterator(Queue<Object[]> queue, WritableRecord key, WritableRecord value, Comparator<Object[]> keyGroupingComparator, boolean incInputRecordCount, com.aliyun.odps.counter.Counters counters)

Method Summary

Modifier and Type	Method and Description
boolean	hasNext()
Record	next()
void	remove()
boolean	reset()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining

Constructor Detail

LocalGroupingRecordIterator

public LocalGroupingRecordIterator(Queue<Object[]> queue,
                                   WritableRecord key,
                                   WritableRecord value,
                                   Comparator<Object[]> keyGroupingComparator,
                                   boolean incInputRecordCount,
                                   com.aliyun.odps.counter.Counters counters)

Method Detail

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<Record>

reset

public boolean reset()

next

public Record next()

Specified by:

next in interface Iterator<Record>

remove

public void remove()

Specified by:

remove in interface Iterator<Record>