Package | Description |
---|---|
org.apache.hadoop.hbase.replication |
Multi Cluster Replication
|
org.apache.hadoop.hbase.replication.regionserver |
Modifier and Type | Method and Description |
---|---|
protected HBaseReplicationEndpoint.SinkPeer |
HBaseReplicationEndpoint.getReplicationSink()
Get a randomly-chosen replication sink to replicate to.
|
Modifier and Type | Method and Description |
---|---|
protected void |
HBaseReplicationEndpoint.reportBadSink(HBaseReplicationEndpoint.SinkPeer sinkPeer)
Report a
SinkPeer as being bad (i.e. |
protected void |
HBaseReplicationEndpoint.reportSinkSuccess(HBaseReplicationEndpoint.SinkPeer sinkPeer)
Report that a
SinkPeer successfully replicated a chunk of data. |
Modifier and Type | Method and Description |
---|---|
private void |
HBaseInterClusterReplicationEndpoint.onReplicateWALEntryException(int entriesHashCode,
Throwable exception,
HBaseReplicationEndpoint.SinkPeer sinkPeer) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.