public class TableRecordReader extends RecordReader<K,V>
Constructor and Description |
---|
TableRecordReader() |
Modifier and Type | Method and Description |
---|---|
void |
close()
Close the record reader.
|
PrimaryKey |
getCurrentKey()
Get the current key.
|
Row |
getCurrentValue()
Get the current value.
|
Table |
getKvTable() |
float |
getProgress()
The current progress of the record reader through its data.
|
void |
initialize(InputSplit split,
TaskAttemptContext context)
Called once at initialization.
|
boolean |
nextKeyValue()
Read the next row.
|
void |
setIndexKey(IndexKey key) |
void |
setIterFailHook(oracle.kv.impl.test.TestHook<RecordValue> iterFailHook) |
void |
setMultiRowOptions(FieldRange fieldRange) |
void |
setPrimaryKey(PrimaryKey key) |
void |
setQueryInfo(int newQueryBy,
String newWhereClause) |
void |
setStore(KVStore testStore)
For testing only; to support the use of a mocked store.
|
protected Row current
public PrimaryKey getCurrentKey() throws IOException, InterruptedException
getCurrentKey
in class RecordReader<PrimaryKey,Row>
IOException
InterruptedException
public Row getCurrentValue() throws IOException, InterruptedException
getCurrentValue
in class RecordReader<PrimaryKey,Row>
IOException
InterruptedException
public void initialize(InputSplit split, TaskAttemptContext context) throws IOException, InterruptedException
initialize
in class RecordReader<K,V>
split
- the split that defines the range of records to readcontext
- the information about the taskIOException
InterruptedException
public boolean nextKeyValue() throws IOException
nextKeyValue
in class RecordReader<K,V>
IOException
public float getProgress()
getProgress
in class RecordReader<K,V>
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class RecordReader<K,V>
IOException
public Table getKvTable()
public void setIndexKey(IndexKey key)
public void setPrimaryKey(PrimaryKey key)
public void setMultiRowOptions(FieldRange fieldRange)
public void setStore(KVStore testStore)
public void setQueryInfo(int newQueryBy, String newWhereClause)
public void setIterFailHook(oracle.kv.impl.test.TestHook<RecordValue> iterFailHook)
Copyright (c) 2011, 2017 Oracle and/or its affiliates. All rights reserved.