Package org.apache.hadoop.hbase.replication

Class ZKReplicationStorageBase

java.lang.Object

org.apache.hadoop.hbase.replication.ZKReplicationStorageBase

Direct Known Subclasses:

ZKReplicationPeerStorage, ZKReplicationQueueStorageForMigration

@Private
public abstract class ZKReplicationStorageBase
extends Object

This is a base class for maintaining replication related data,for example, peer, queue, etc, in zookeeper.

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.apache.hadoop.conf.Configuration	conf
static final String	REPLICATION_ZNODE
static final String	REPLICATION_ZNODE_DEFAULT
protected final String	replicationZNode	The name of the base znode that contains all replication state.
protected final ZKWatcher	zookeeper

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ZKReplicationStorageBase(ZKWatcher zookeeper, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method	Description
protected static byte[]	toByteArray(org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.ReplicationState.State state)	Serialized protobuf of state with pb magic prefix prepended suitable for use as content of a peer-state znode under a peer cluster id as in /hbase/replication/peers/PEER_ID/peer-state.

Methods inherited from class java.lang.Object

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

Field Details

REPLICATION_ZNODE

public static final String REPLICATION_ZNODE

See Also:

• Constant Field Values

REPLICATION_ZNODE_DEFAULT

public static final String REPLICATION_ZNODE_DEFAULT

See Also:

• Constant Field Values

replicationZNode

protected final String replicationZNode

The name of the base znode that contains all replication state.

zookeeper

protected final ZKWatcher zookeeper

conf

protected final org.apache.hadoop.conf.Configuration conf

Constructor Details

ZKReplicationStorageBase

protected ZKReplicationStorageBase(ZKWatcher zookeeper,
 org.apache.hadoop.conf.Configuration conf)

Method Details

toByteArray

protected static byte[] toByteArray(org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.ReplicationState.State state)

Serialized protobuf of state with pb magic prefix prepended suitable for use as content of a peer-state znode under a peer cluster id as in /hbase/replication/peers/PEER_ID/peer-state.