public class TableRecordReaderImpl
extends java.lang.Object
Constructor and Description |
---|
TableRecordReaderImpl() |
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.
|
public void close()
public org.ojai.Value getCurrentKey() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public org.ojai.Document getCurrentValue() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public boolean nextKeyValue() throws java.io.IOException, java.lang.InterruptedException
true
if there is a row.java.io.IOException
java.lang.InterruptedException
public void initialize(org.apache.hadoop.mapreduce.InputSplit inputsplit, org.apache.hadoop.mapreduce.TaskAttemptContext cntxt) throws java.io.IOException, java.lang.InterruptedException
inputsplit
- split on which the iterator is to be initialized.cntxt
- current task context.java.io.IOException
java.lang.InterruptedException
public void setTable(com.mapr.db.Table t)
t
- input table.public void setCondition(org.ojai.store.QueryCondition c)
public void setFieldPath(java.lang.String fieldPath)