com.mapr.db.mapreduce

Class TableRecordReaderImpl

java.lang.Object

com.mapr.db.mapreduce.TableRecordReaderImpl

public class TableRecordReaderImpl
extends java.lang.Object

Iterates over MapR-DB JSON table data. Returns key, value pair as ByteBufWritableComparable and Document respectively.

Constructor Summary

Constructors

Constructor and Description
TableRecordReaderImpl()

Method Summary

Modifier and Type	Method and Description
void	close() Close current split.
org.ojai.Value	getCurrentKey() Returns current key.
org.ojai.Document	getCurrentValue() Returns current value as Document.
void	initialize(org.apache.hadoop.mapreduce.InputSplit inputsplit, org.apache.hadoop.mapreduce.TaskAttemptContext cntxt) Initialize reader/iterator.
boolean	nextKeyValue() Positions reader/iterator to the next row.
void	setCondition(org.ojai.store.QueryCondition c)
void	setFieldPath(java.lang.String fieldPath)
void	setTable(com.mapr.db.Table t) Sets table name.

Methods inherited from class java.lang.Object

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

Constructor Detail

TableRecordReaderImpl

public TableRecordReaderImpl()

Method Detail

close

public void close()

Close current split.

getCurrentKey

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

Returns current key.

Returns:

current key.

Throws:

java.io.IOException

java.lang.InterruptedException

getCurrentValue

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

Returns current value as Document.

Returns:

current document.

Throws:

java.io.IOException

java.lang.InterruptedException

nextKeyValue

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

Positions reader/iterator to the next row.

Returns:

true if there is a row.

Throws:

java.io.IOException

java.lang.InterruptedException

initialize

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

Initialize reader/iterator.

Parameters:

inputsplit - split on which the iterator is to be initialized.

cntxt - current task context.

Throws:

java.io.IOException

java.lang.InterruptedException

setTable

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

Sets table name.

Parameters:

t - input table.

setCondition

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

setFieldPath

public void setFieldPath(java.lang.String fieldPath)