TableRecordReaderImpl (Apache HBase 2.5.0 API)

java.lang.Object
- org.apache.hadoop.hbase.mapred.TableRecordReaderImpl

@InterfaceAudience.Public
public class TableRecordReaderImpl
extends Object

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

Field Summary

Fields
Modifier and Type	Field and Description
`private byte[]`	`endRow`
`private Table`	`htable`
`private byte[]`	`lastSuccessfulRow`
`private static 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 and Description

TableRecordReaderImpl()

Constructors
Constructor and Description
`TableRecordReaderImpl()`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`close()`
`ImmutableBytesWritable`	`createKey()` n *
`Result`	`createValue()` n *
`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 Detail

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 Detail
- TableRecordReaderImpl
```
public TableRecordReaderImpl()
```

Method Detail
- 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()
```
  n *
  
  See Also:
  
  RecordReader.createKey()
- createValue
```
public Result createValue()
```
  n *
  
  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

Class TableRecordReaderImpl

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

LOG

startRow

endRow

lastSuccessfulRow

trrRowFilter

scanner

htable

trrInputColumns

timestamp

rowcount

logScannerActivity

logPerRowCount

Constructor Detail

TableRecordReaderImpl

Method Detail

restart

init

getStartRow

setHTable

setInputColumns

setStartRow

setEndRow

setRowFilter

close

createKey

createValue

getPos

getProgress

next