org.apache.gora.mapreduce

Class GoraRecordReader<K,T extends PersistentBase>

java.lang.Object

org.apache.hadoop.mapreduce.RecordReader<K,T>

org.apache.gora.mapreduce.GoraRecordReader<K,T>

All Implemented Interfaces:

Closeable, AutoCloseable

public class GoraRecordReader<K,T extends PersistentBase>
extends org.apache.hadoop.mapreduce.RecordReader<K,T>

An adapter for Result to Hadoop RecordReader.

Field Summary

Fields

Modifier and Type	Field and Description
static String	BUFFER_LIMIT_READ_NAME
static int	BUFFER_LIMIT_READ_VALUE
static org.slf4j.Logger	LOG
protected Query<K,T>	query
protected Result<K,T>	result

Constructor Summary

Constructors

Constructor and Description
GoraRecordReader(Query<K,T> query, org.apache.hadoop.mapreduce.TaskAttemptContext context)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	executeQuery()
K	getCurrentKey()
T	getCurrentValue()
float	getProgress()
void	initialize(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context)
boolean	nextKeyValue()

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.slf4j.Logger LOG

BUFFER_LIMIT_READ_NAME

public static final String BUFFER_LIMIT_READ_NAME

See Also:

Constant Field Values

BUFFER_LIMIT_READ_VALUE

public static final int BUFFER_LIMIT_READ_VALUE

See Also:

Constant Field Values

query

protected Query<K,T extends PersistentBase> query

result

protected Result<K,T extends PersistentBase> result

Constructor Detail

GoraRecordReader

public GoraRecordReader(Query<K,T> query,
                org.apache.hadoop.mapreduce.TaskAttemptContext context)

Method Detail

executeQuery

public void executeQuery()
                  throws IOException,
                         Exception

Throws:

IOException

Exception

getCurrentKey

public K getCurrentKey()
                throws IOException,
                       InterruptedException

Specified by:

getCurrentKey in class org.apache.hadoop.mapreduce.RecordReader<K,T extends PersistentBase>

Throws:

IOException

InterruptedException

getCurrentValue

public T getCurrentValue()
                                         throws IOException,
                                                InterruptedException

Specified by:

getCurrentValue in class org.apache.hadoop.mapreduce.RecordReader<K,T extends PersistentBase>

Throws:

IOException

InterruptedException

getProgress

public float getProgress()
                  throws IOException,
                         InterruptedException

Specified by:

getProgress in class org.apache.hadoop.mapreduce.RecordReader<K,T extends PersistentBase>

Throws:

IOException

InterruptedException

initialize

public void initialize(org.apache.hadoop.mapreduce.InputSplit split,
              org.apache.hadoop.mapreduce.TaskAttemptContext context)
                throws IOException,
                       InterruptedException

Specified by:

initialize in class org.apache.hadoop.mapreduce.RecordReader<K,T extends PersistentBase>

Throws:

IOException

InterruptedException

nextKeyValue

public boolean nextKeyValue()
                     throws IOException,
                            InterruptedException

Specified by:

nextKeyValue in class org.apache.hadoop.mapreduce.RecordReader<K,T extends PersistentBase>

Throws:

IOException

InterruptedException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in class org.apache.hadoop.mapreduce.RecordReader<K,T extends PersistentBase>

Throws:

IOException