org.apache.hadoop.zebra.mapred

Class TableRecordReader

java.lang.Object

org.apache.hadoop.zebra.mapred.TableRecordReader

All Implemented Interfaces:

org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.BytesWritable,Tuple>

Deprecated.

@Deprecated
public class TableRecordReader
extends Object
implements org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.BytesWritable,Tuple>

Adaptor class to implement RecordReader on top of Scanner.

Constructor Summary

Constructors

Constructor and Description
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

Methods

Modifier and Type	Method and Description
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

TableRecordReader

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

Deprecated.

Parameters:

expr - Table expression

projection - projection schema. Should never be null.

split - the split to work on

conf - JobConf object

Throws:

IOException

ParseException

Method Detail

close

public void close()
           throws IOException

Deprecated.

Specified by:

close in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.BytesWritable,Tuple>

Throws:

IOException

createKey

public org.apache.hadoop.io.BytesWritable createKey()

Deprecated.

Specified by:

createKey in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.BytesWritable,Tuple>

createValue

public Tuple createValue()

Deprecated.

Specified by:

createValue in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.BytesWritable,Tuple>

getPos

public long getPos()
            throws IOException

Deprecated.

Specified by:

getPos in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.BytesWritable,Tuple>

Throws:

IOException

getProgress

public float getProgress()
                  throws IOException

Deprecated.

Specified by:

getProgress in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.BytesWritable,Tuple>

Throws:

IOException

next

public boolean next(org.apache.hadoop.io.BytesWritable key,
           Tuple value)
             throws IOException

Deprecated.

Specified by:

next in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.BytesWritable,Tuple>

Throws:

IOException

seekTo

public boolean seekTo(org.apache.hadoop.io.BytesWritable key)
               throws IOException

Deprecated.

Seek to the position at the first row which has the key or just after the key; only applicable for sorted Zebra table

Parameters:

key - the key to seek on

Throws:

IOException

atEnd

public boolean atEnd()
              throws IOException

Deprecated.

Check if the end of the input has been reached

Returns:

true if the end of the input is reached

Throws:

IOException