org.apache.hadoop.hbase.replication

Class ZKReplicationStorageBase

java.lang.Object

org.apache.hadoop.hbase.replication.ZKReplicationStorageBase

Direct Known Subclasses:

ZKReplicationPeerStorage

@InterfaceAudience.Private
public 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 and Description
protected org.apache.hadoop.conf.Configuration	conf
static String	REPLICATION_ZNODE
static String	REPLICATION_ZNODE_DEFAULT
protected String	replicationZNode The name of the base znode that contains all replication state.
protected ZKWatcher	zookeeper

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected static byte[]	toByteArray(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 Detail

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 Detail

ZKReplicationStorageBase

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

Method Detail

toByteArray

protected static byte[] toByteArray(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.