Field Detail

• LOG_PER_ROW_COUNT

  public static final String LOG_PER_ROW_COUNT

  See Also:

  Constant Field Values

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 - The first row to start at.

  Throws:

  IOException - When restarting fails.

• retrieveGetCounterWithStringsParams

  protected static Method retrieveGetCounterWithStringsParams(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                       throws IOException

  In new mapreduce APIs, TaskAttemptContext has two getCounter methods Check if getCounter(String, String) method is available.

  Returns:

  The getCounter method or null if not available.

  Throws:

  IOException

• setHTable

  public void setHTable(Table htable)

  Sets the HBase table.

  Parameters:

  htable - The HTableDescriptor to scan.

• setScan

  public void setScan(Scan scan)

  Sets the scan defining the actual details like columns etc.

  Parameters:

  scan - The scan to set.

• initialize

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

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

  Throws:

  IOException

  InterruptedException

• close

  public void close()

  Closes the split.

• getCurrentKey

  public ImmutableBytesWritable getCurrentKey()
                                       throws IOException,
                                              InterruptedException

  Returns the current key.

  Returns:

  The current key.

  Throws:

  IOException

  InterruptedException - When the job is aborted.

• getCurrentValue

  public Result getCurrentValue()
                         throws IOException,
                                InterruptedException

  Returns the current value.

  Returns:

  The current value.

  Throws:

  IOException - When the value is faulty.

  InterruptedException - When the job is aborted.

• nextKeyValue

  public boolean nextKeyValue()
                       throws IOException,
                              InterruptedException

  Positions the record reader to the next record.

  Returns:

  true if there was another record.

  Throws:

  IOException - When reading the record failed.

  InterruptedException - When the job was aborted.

• updateCounters

  protected static void updateCounters(ScanMetrics scanMetrics,
                    long numScannerRestarts,
                    Method getCounter,
                    org.apache.hadoop.mapreduce.TaskAttemptContext context,
                    long numStale)

• getProgress

  public float getProgress()

  The current progress of the record reader through its data.

  Returns:

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