org.apache.hadoop.hbase.regionserver.wal

Class WALEditsReplaySink

java.lang.Object

org.apache.hadoop.hbase.regionserver.wal.WALEditsReplaySink

@InterfaceAudience.Private
public class WALEditsReplaySink
extends Object

This class is responsible for replaying the edits coming from a failed region server.

This class uses the native HBase client in order to replay WAL entries.

Constructor Summary

Constructors

Constructor and Description
WALEditsReplaySink(org.apache.hadoop.conf.Configuration conf, TableName tableName, HConnection conn) Create a sink for WAL log entries replay

Method Summary

Methods

Modifier and Type	Method and Description
String	getStats() Get a string representation of this sink's metrics
void	replayEntries(List<Pair<HRegionLocation,HLog.Entry>> entries) Replay an array of actions of the same region directly into the newly assigned Region Server

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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,HLog.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