@InterfaceAudience.Private public class WALEditsReplaySink extends java.lang.Object
Constructor and Description |
---|
WALEditsReplaySink(Configuration conf,
TableName tableName,
HConnection conn)
Create a sink for WAL log entries replay
|
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getStats()
Get a string representation of this sink's metrics
|
void |
replayEntries(java.util.List<Pair<HRegionLocation,WAL.Entry>> entries)
Replay an array of actions of the same region directly into the newly assigned Region Server
|
public WALEditsReplaySink(Configuration conf, TableName tableName, HConnection conn) throws java.io.IOException
conf
- tableName
- conn
- java.io.IOException
public void replayEntries(java.util.List<Pair<HRegionLocation,WAL.Entry>> entries) throws java.io.IOException
entries
- java.io.IOException
public java.lang.String getStats()