Constructor Detail

• TableRecordReaderImpl

  public TableRecordReaderImpl()

Method Detail

• restart

  public void restart(byte[] firstRow)
               throws IOException

  Restart from survivable exceptions by creating a new scanner.

  Parameters:

  firstRow -

  Throws:

  IOException

• init

  public void init()
            throws IOException

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

  Throws:

  IOException

• 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()

  Returns:

  ImmutableBytesWritable

  See Also:

  RecordReader.createKey()

• createValue

  public Result createValue()

  Returns:

  RowResult

  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