org.apache.hadoop.hbase.zookeeper

Class LoadBalancerTracker

java.lang.Object

org.apache.hadoop.hbase.zookeeper.ZKListener

org.apache.hadoop.hbase.zookeeper.ZKNodeTracker

org.apache.hadoop.hbase.zookeeper.LoadBalancerTracker

@InterfaceAudience.Private
public class LoadBalancerTracker
extends ZKNodeTracker

Tracks the load balancer state up in ZK

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG

Fields inherited from class org.apache.hadoop.hbase.zookeeper.ZKNodeTracker

abortable, node

Fields inherited from class org.apache.hadoop.hbase.zookeeper.ZKListener

watcher

Constructor Summary

Constructors

Constructor and Description
LoadBalancerTracker(ZKWatcher watcher, Abortable abortable)

Method Summary

Modifier and Type	Method and Description
boolean	isBalancerOn() Return true if the balance switch is on, false otherwise
private org.apache.hadoop.hbase.shaded.protobuf.generated.LoadBalancerProtos.LoadBalancerState	parseFrom(byte[] pbBytes)
void	setBalancerOn(boolean balancerOn) Set the balancer on/off.
private byte[]	toByteArray(boolean isBalancerOn)

Methods inherited from class org.apache.hadoop.hbase.zookeeper.ZKNodeTracker

blockUntilAvailable, blockUntilAvailable, checkIfBaseNodeAvailable, getData, getNode, nodeCreated, nodeDataChanged, nodeDeleted, start, stop, toString

Methods inherited from class org.apache.hadoop.hbase.zookeeper.ZKListener

getWatcher, nodeChildrenChanged

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

Constructor Detail

LoadBalancerTracker

public LoadBalancerTracker(ZKWatcher watcher,
                           Abortable abortable)

Method Detail

isBalancerOn

public boolean isBalancerOn()

Return true if the balance switch is on, false otherwise

setBalancerOn

public void setBalancerOn(boolean balancerOn)
                   throws org.apache.zookeeper.KeeperException

Set the balancer on/off.

Parameters:

balancerOn - true if the balancher should be on, false otherwise

Throws:

org.apache.zookeeper.KeeperException - if a ZooKeeper operation fails

toByteArray

private byte[] toByteArray(boolean isBalancerOn)

parseFrom

private org.apache.hadoop.hbase.shaded.protobuf.generated.LoadBalancerProtos.LoadBalancerState parseFrom(byte[] pbBytes)
                                                                                                  throws DeserializationException

Throws:

DeserializationException