@InterfaceAudience.Private public class WALEditsReplaySink extends Object
This class uses the native HBase client in order to replay WAL entries.
Constructor and Description |
---|
WALEditsReplaySink(org.apache.hadoop.conf.Configuration conf,
TableName tableName,
HConnection conn)
Create a sink for WAL log entries replay
|
Modifier and Type | Method and Description |
---|---|
String |
getStats()
Get a string representation of this sink's metrics
|
void |
replayEntries(List<Pair<HRegionLocation,WAL.Entry>> entries)
Replay an array of actions of the same region directly into the newly assigned Region Server
|
public WALEditsReplaySink(org.apache.hadoop.conf.Configuration conf, TableName tableName, HConnection conn) throws IOException
conf
- tableName
- conn
- IOException
public void replayEntries(List<Pair<HRegionLocation,WAL.Entry>> entries) throws IOException
entries
- IOException
public String getStats()
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.