|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.hadoop.zebra.mapred.TableRecordReader
@Deprecated public class TableRecordReader
Adaptor class to implement RecordReader on top of Scanner.
Constructor Summary | |
---|---|
TableRecordReader(org.apache.hadoop.zebra.mapred.TableExpr expr,
String projection,
org.apache.hadoop.mapred.InputSplit split,
org.apache.hadoop.mapred.JobConf conf)
Deprecated. |
Method Summary | |
---|---|
boolean |
atEnd()
Deprecated. Check if the end of the input has been reached |
void |
close()
Deprecated. |
org.apache.hadoop.io.BytesWritable |
createKey()
Deprecated. |
Tuple |
createValue()
Deprecated. |
long |
getPos()
Deprecated. |
float |
getProgress()
Deprecated. |
boolean |
next(org.apache.hadoop.io.BytesWritable key,
Tuple value)
Deprecated. |
boolean |
seekTo(org.apache.hadoop.io.BytesWritable key)
Deprecated. Seek to the position at the first row which has the key or just after the key; only applicable for sorted Zebra table |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public TableRecordReader(org.apache.hadoop.zebra.mapred.TableExpr expr, String projection, org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.mapred.JobConf conf) throws IOException, ParseException
expr
- Table expressionprojection
- projection schema. Should never be null.split
- the split to work onconf
- JobConf object
IOException
ParseException
Method Detail |
---|
public void close() throws IOException
close
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.BytesWritable,Tuple>
IOException
public org.apache.hadoop.io.BytesWritable createKey()
createKey
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.BytesWritable,Tuple>
public Tuple createValue()
createValue
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.BytesWritable,Tuple>
public long getPos() throws IOException
getPos
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.BytesWritable,Tuple>
IOException
public float getProgress() throws IOException
getProgress
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.BytesWritable,Tuple>
IOException
public boolean next(org.apache.hadoop.io.BytesWritable key, Tuple value) throws IOException
next
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.BytesWritable,Tuple>
IOException
public boolean seekTo(org.apache.hadoop.io.BytesWritable key) throws IOException
key
- the key to seek on
IOException
public boolean atEnd() throws IOException
IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |