org.apache.accumulo.server.master
Class LiveTServerSet

java.lang.Object
  extended by org.apache.accumulo.server.master.LiveTServerSet
All Implemented Interfaces:
org.apache.zookeeper.Watcher

public class LiveTServerSet
extends Object
implements org.apache.zookeeper.Watcher


Nested Class Summary
static interface LiveTServerSet.Listener
           
 class LiveTServerSet.TServerConnection
           
 
Nested classes/interfaces inherited from interface org.apache.zookeeper.Watcher
org.apache.zookeeper.Watcher.Event
 
Constructor Summary
LiveTServerSet(Instance instance, AccumuloConfiguration conf, LiveTServerSet.Listener cback)
           
 
Method Summary
 TServerInstance find(String serverName)
           
 LiveTServerSet.TServerConnection getConnection(TServerInstance server)
           
 Set<TServerInstance> getCurrentServers()
           
 ZooCache getZooCache()
           
 boolean isOnline(String serverName)
           
 void process(org.apache.zookeeper.WatchedEvent event)
           
 void remove(TServerInstance server)
           
 void scanServers()
           
 int size()
           
 void startListeningForTabletServerChanges()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

LiveTServerSet

public LiveTServerSet(Instance instance,
                      AccumuloConfiguration conf,
                      LiveTServerSet.Listener cback)
Method Detail

getZooCache

public ZooCache getZooCache()

startListeningForTabletServerChanges

public void startListeningForTabletServerChanges()

scanServers

public void scanServers()

process

public void process(org.apache.zookeeper.WatchedEvent event)
Specified by:
process in interface org.apache.zookeeper.Watcher

getConnection

public LiveTServerSet.TServerConnection getConnection(TServerInstance server)
                                               throws org.apache.thrift.TException
Throws:
org.apache.thrift.TException

getCurrentServers

public Set<TServerInstance> getCurrentServers()

size

public int size()

find

public TServerInstance find(String serverName)

isOnline

public boolean isOnline(String serverName)

remove

public void remove(TServerInstance server)


Copyright © 2013 Apache Accumulo Project. All Rights Reserved.