org.apache.hadoop.hbase.replication.regionserver
Class ReplicationSink
java.lang.Object
org.apache.hadoop.hbase.replication.regionserver.ReplicationSink
public class ReplicationSink
- extends Object
This class is responsible for replicating the edits coming
from another cluster.
This replication process is currently waiting for the edits to be applied
before the method can return. This means that the replication of edits
is synchronized (after reading from HLogs in ReplicationSource) and that a
single region server cannot receive edits from two sources at the same time
This class uses the native HBase client in order to replicate entries.
TODO make this class more like ReplicationSource wrt log handling
Constructor Summary |
ReplicationSink(org.apache.hadoop.conf.Configuration conf,
Stoppable stopper)
Create a sink for replication |
Method Summary |
void |
replicateEntries(HLog.Entry[] entries)
Replicate this array of entries directly into the local cluster
using the native client. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
REPLICATION_LOG_DIR
public static final String REPLICATION_LOG_DIR
- See Also:
- Constant Field Values
ReplicationSink
public ReplicationSink(org.apache.hadoop.conf.Configuration conf,
Stoppable stopper)
throws IOException
- Create a sink for replication
- Parameters:
conf
- conf objectstopper
- boolean to tell this thread to stop
- Throws:
IOException
- thrown when HDFS goes bad or bad file name
replicateEntries
public void replicateEntries(HLog.Entry[] entries)
throws IOException
- Replicate this array of entries directly into the local cluster
using the native client.
- Parameters:
entries
-
- Throws:
IOException
Copyright © 2011 The Apache Software Foundation. All Rights Reserved.