com.asakusafw.runtime.mapreduce.simple

Class ShuffleReader

java.lang.Object

com.asakusafw.runtime.mapreduce.simple.ShuffleReader

All Implemented Interfaces:

org.apache.hadoop.mapred.RawKeyValueIterator

public class ShuffleReader
extends Object
implements org.apache.hadoop.mapred.RawKeyValueIterator

Read shuffle outputs.

Since:

0.7.1

Constructor Summary

Constructors

Constructor and Description
ShuffleReader(KeyValueSorter<?,?> sorter, org.apache.hadoop.util.Progress progress) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	close()
org.apache.hadoop.io.DataInputBuffer	getKey()
org.apache.hadoop.util.Progress	getProgress()
org.apache.hadoop.io.DataInputBuffer	getValue()
boolean	next()

Methods inherited from class java.lang.Object

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

Constructor Detail

ShuffleReader

public ShuffleReader(KeyValueSorter<?,?> sorter,
                     org.apache.hadoop.util.Progress progress)

Creates a new instance.

Parameters:

sorter - the source sorter

progress - the progress

Method Detail

next

public boolean next()
             throws IOException

Specified by:

next in interface org.apache.hadoop.mapred.RawKeyValueIterator

Throws:

IOException

getKey

public org.apache.hadoop.io.DataInputBuffer getKey()
                                            throws IOException

Specified by:

getKey in interface org.apache.hadoop.mapred.RawKeyValueIterator

Throws:

IOException

getValue

public org.apache.hadoop.io.DataInputBuffer getValue()
                                              throws IOException

Specified by:

getValue in interface org.apache.hadoop.mapred.RawKeyValueIterator

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface org.apache.hadoop.mapred.RawKeyValueIterator

Throws:

IOException

getProgress

public org.apache.hadoop.util.Progress getProgress()

Specified by:

getProgress in interface org.apache.hadoop.mapred.RawKeyValueIterator