Field Detail

• LOG

  private static final org.apache.commons.logging.Log LOG

• MAX_BATCH_SIZE

  private static final int MAX_BATCH_SIZE

  See Also:

  Constant Field Values

• conf

  private final org.apache.hadoop.conf.Configuration conf

• conn

  private final HConnection conn

• tableName

  private final TableName tableName

• metrics

  private final MetricsWALEditsReplay metrics

• totalReplayedEdits

  private final AtomicLong totalReplayedEdits

• skipErrors

  private final boolean skipErrors

• replayTimeout

  private final int replayTimeout

• rpcControllerFactory

  private RpcControllerFactory rpcControllerFactory

Constructor Detail

• WALEditsReplaySink

  public WALEditsReplaySink(org.apache.hadoop.conf.Configuration conf,
                    TableName tableName,
                    HConnection conn)
                     throws IOException

  Create a sink for WAL log entries replay

  Parameters:

  conf -

  tableName -

  conn -

  Throws:

  IOException

Method Detail

• replayEntries

  public void replayEntries(List<Pair<HRegionLocation,WAL.Entry>> entries)
                     throws IOException

  Replay an array of actions of the same region directly into the newly assigned Region Server

  Parameters:

  entries -

  Throws:

  IOException

• getStats

  public String getStats()

  Get a string representation of this sink's metrics

  Returns:

  string with the total replayed edits count

• replayEdits

  private void replayEdits(HRegionLocation regionLoc,
                 HRegionInfo regionInfo,
                 List<WAL.Entry> entries)
                    throws IOException

  Throws:

  IOException