com.mapr.db.mapreduce

Class TableRecordReader

java.lang.Object

org.apache.hadoop.mapreduce.RecordReader<org.ojai.Value,org.ojai.Document>

com.mapr.db.mapreduce.TableRecordReader

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class TableRecordReader
extends org.apache.hadoop.mapreduce.RecordReader<org.ojai.Value,org.ojai.Document>

Top level wrapper class which iterates over rows in a JSON table and returns (Key, Value) pairs, where value is a document.

Constructor Summary

Constructors

Constructor and Description
TableRecordReader()

Method Summary

Modifier and Type	Method and Description
void	close() Closes the split.
org.ojai.Value	getCurrentKey() Returns the current key.
org.ojai.Document	getCurrentValue() Returns the current value.
float	getProgress() The current progress of the record reader through its data.
void	initialize(org.apache.hadoop.mapreduce.InputSplit inputsplit, org.apache.hadoop.mapreduce.TaskAttemptContext context) Initializes the reader.
boolean	nextKeyValue() Positions the record reader to the next record.
void	setCondition(org.ojai.store.QueryCondition c)
void	setFieldPath(java.lang.String fieldPath)
void	setTable(com.mapr.db.Table jTable)

Methods inherited from class java.lang.Object

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

Constructor Detail

TableRecordReader

public TableRecordReader()

Method Detail

close

public void close()

Closes the split.

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in class org.apache.hadoop.mapreduce.RecordReader<org.ojai.Value,org.ojai.Document>

See Also:

RecordReader.close()

getCurrentKey

public org.ojai.Value getCurrentKey()
                             throws java.io.IOException,
                                    java.lang.InterruptedException

Returns the current key.

Specified by:

getCurrentKey in class org.apache.hadoop.mapreduce.RecordReader<org.ojai.Value,org.ojai.Document>

Returns:

The current key.

Throws:

java.io.IOException

java.lang.InterruptedException - When the job is aborted.

See Also:

RecordReader.getCurrentKey()

getCurrentValue

public org.ojai.Document getCurrentValue()
                                  throws java.io.IOException,
                                         java.lang.InterruptedException

Returns the current value.

Specified by:

getCurrentValue in class org.apache.hadoop.mapreduce.RecordReader<org.ojai.Value,org.ojai.Document>

Returns:

The current value.

Throws:

java.io.IOException - When the value is faulty.

java.lang.InterruptedException - When the job is aborted.

See Also:

RecordReader.getCurrentValue()

initialize

public void initialize(org.apache.hadoop.mapreduce.InputSplit inputsplit,
                       org.apache.hadoop.mapreduce.TaskAttemptContext context)
                throws java.io.IOException,
                       java.lang.InterruptedException

Initializes the reader.

Specified by:

initialize in class org.apache.hadoop.mapreduce.RecordReader<org.ojai.Value,org.ojai.Document>

Parameters:

inputsplit - The split to work with.

context - The current task context.

Throws:

java.io.IOException - When setting up the reader fails.

java.lang.InterruptedException - When the job is aborted.

See Also:

RecordReader.initialize( org.apache.hadoop.mapreduce.InputSplit, org.apache.hadoop.mapreduce.TaskAttemptContext)

nextKeyValue

public boolean nextKeyValue()
                     throws java.io.IOException,
                            java.lang.InterruptedException

Positions the record reader to the next record.

Specified by:

nextKeyValue in class org.apache.hadoop.mapreduce.RecordReader<org.ojai.Value,org.ojai.Document>

Returns:

true if there was another record.

Throws:

java.io.IOException - When reading the record failed.

java.lang.InterruptedException - When the job was aborted.

See Also:

RecordReader.nextKeyValue()

getProgress

public float getProgress()

The current progress of the record reader through its data.

Specified by:

getProgress in class org.apache.hadoop.mapreduce.RecordReader<org.ojai.Value,org.ojai.Document>

Returns:

A number between 0.0 and 1.0, the fraction of the data read.

See Also:

RecordReader.getProgress()

setTable

public void setTable(com.mapr.db.Table jTable)

setCondition

public void setCondition(org.ojai.store.QueryCondition c)

setFieldPath

public void setFieldPath(java.lang.String fieldPath)