Package org.apache.hadoop.hbase.mapred

Class TableRecordReaderImpl

java.lang.Object

org.apache.hadoop.hbase.mapred.TableRecordReaderImpl

@Public
public class TableRecordReaderImpl
extends Object

Iterate over an HBase table data, return (Text, RowResult) pairs

Field Summary

Fields

Modifier and Type	Field	Description
private byte[]	endRow
private Table	htable
private byte[]	lastSuccessfulRow
private static final org.slf4j.Logger	LOG
private int	logPerRowCount
private boolean	logScannerActivity
private int	rowcount
private ResultScanner	scanner
private byte[]	startRow
private long	timestamp
private byte[][]	trrInputColumns
private Filter	trrRowFilter

Constructor Summary

Constructors

Constructor	Description
TableRecordReaderImpl()

Method Summary

Modifier and Type	Method	Description
void	close()
ImmutableBytesWritable	createKey()
Result	createValue()
long	getPos()
float	getProgress()
(package private) byte[]	getStartRow()
void	init()	Build the scanner.
boolean	next(ImmutableBytesWritable key, Result value)
void	restart(byte[] firstRow)	Restart from survivable exceptions by creating a new scanner.
void	setEndRow(byte[] endRow)
void	setHTable(Table htable)
void	setInputColumns(byte[][] inputColumns)
void	setRowFilter(Filter rowFilter)
void	setStartRow(byte[] startRow)

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

startRow

private byte[] startRow

endRow

private byte[] endRow

lastSuccessfulRow

private byte[] lastSuccessfulRow

trrRowFilter

private Filter trrRowFilter

scanner

private ResultScanner scanner

htable

private Table htable

trrInputColumns

private byte[][] trrInputColumns

timestamp

private long timestamp

rowcount

private int rowcount

logScannerActivity

private boolean logScannerActivity

logPerRowCount

private int logPerRowCount

Constructor Details

TableRecordReaderImpl

public TableRecordReaderImpl()

Method Details

restart

public void restart(byte[] firstRow)
             throws IOException

Restart from survivable exceptions by creating a new scanner.

Throws:

IOException

init

public void init()
          throws IOException

Build the scanner. Not done in constructor to allow for extension.

Throws:

IOException

getStartRow

byte[] getStartRow()

setHTable

public void setHTable(Table htable)

Parameters:

htable - the HTableDescriptor to scan.

setInputColumns

public void setInputColumns(byte[][] inputColumns)

Parameters:

inputColumns - the columns to be placed in Result.

setStartRow

public void setStartRow(byte[] startRow)

Parameters:

startRow - the first row in the split

setEndRow

public void setEndRow(byte[] endRow)

Parameters:

endRow - the last row in the split

setRowFilter

public void setRowFilter(Filter rowFilter)

Parameters:

rowFilter - the Filter to be used.

close

public void close()

createKey

public ImmutableBytesWritable createKey()

See Also:

• RecordReader.createKey()

createValue

public Result createValue()

See Also:

• RecordReader.createValue()

getPos

public long getPos()

getProgress

public float getProgress()

next

public boolean next(ImmutableBytesWritable key,
 Result value)
             throws IOException

Parameters:

key - HStoreKey as input key.

value - MapWritable as input value

Returns:

true if there was more data

Throws:

IOException