Field Detail

• recordReaderImpl

  private TableRecordReaderImpl recordReaderImpl

Constructor Detail

• TableRecordReader

  public TableRecordReader()

Method Detail

• restart

  public void restart(byte[] firstRow)
               throws IOException

  Restart from survivable exceptions by creating a new scanner.

  Parameters:

  firstRow - The first row to start at.

  Throws:

  IOException - When restarting fails.

• setHTable

  @Deprecated
  public void setHTable(Table htable)

  Deprecated. Use setTable() instead.
  Sets the HBase table.

  Parameters:

  htable - The table to scan.

• setTable

  public void setTable(Table table)

  Parameters:

  table - the Table to scan.

• setScan

  public void setScan(Scan scan)

  Sets the scan defining the actual details like columns etc.

  Parameters:

  scan - The scan to set.

• close

  public void close()

  Closes the split.

  Specified by:

  close in interface Closeable

  Specified by:

  close in interface AutoCloseable

  Specified by:

  close in class org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>

  See Also:

  RecordReader.close()

• getCurrentKey

  public ImmutableBytesWritable getCurrentKey()
                                       throws IOException,
                                              InterruptedException

  Returns the current key.

  Specified by:

  getCurrentKey in class org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>

  Returns:

  The current key.

  Throws:

  IOException

  InterruptedException - When the job is aborted.

  See Also:

  RecordReader.getCurrentKey()

• getCurrentValue

  public Result getCurrentValue()
                         throws IOException,
                                InterruptedException

  Returns the current value.

  Specified by:

  getCurrentValue in class org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>

  Returns:

  The current value.

  Throws:

  IOException - When the value is faulty.

  InterruptedException - When the job is aborted.

  See Also:

  RecordReader.getCurrentValue()

• initialize

  public void initialize(org.apache.hadoop.mapreduce.InputSplit inputsplit,
                org.apache.hadoop.mapreduce.TaskAttemptContext context)
                  throws IOException,
                         InterruptedException

  Initializes the reader.

  Specified by:

  initialize in class org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>

  Parameters:

  inputsplit - The split to work with.

  context - The current task context.

  Throws:

  IOException - When setting up the reader fails.

  InterruptedException - When the job is aborted.

  See Also:

  RecordReader.initialize( org.apache.hadoop.mapreduce.InputSplit, org.apache.hadoop.mapreduce.TaskAttemptContext)

• nextKeyValue

  public boolean nextKeyValue()
                       throws IOException,
                              InterruptedException

  Positions the record reader to the next record.

  Specified by:

  nextKeyValue in class org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>

  Returns:

  true if there was another record.

  Throws:

  IOException - When reading the record failed.

  InterruptedException - When the job was aborted.

  See Also:

  RecordReader.nextKeyValue()

• getProgress

  public float getProgress()

  The current progress of the record reader through its data.

  Specified by:

  getProgress in class org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>

  Returns:

  A number between 0.0 and 1.0, the fraction of the data read.

  See Also:

  RecordReader.getProgress()