org.apache.accumulo.server.master
public class LiveTServerSet extends Object implements org.apache.zookeeper.Watcher
Modifier and Type | Class and Description |
---|---|
static interface |
LiveTServerSet.Listener |
class |
LiveTServerSet.TServerConnection |
Constructor and Description |
---|
LiveTServerSet(Instance instance,
AccumuloConfiguration conf,
LiveTServerSet.Listener cback) |
Modifier and Type | Method and Description |
---|---|
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() |
public LiveTServerSet(Instance instance, AccumuloConfiguration conf, LiveTServerSet.Listener cback)
public ZooCache getZooCache()
public void startListeningForTabletServerChanges()
public void scanServers()
public void process(org.apache.zookeeper.WatchedEvent event)
process
in interface org.apache.zookeeper.Watcher
public LiveTServerSet.TServerConnection getConnection(TServerInstance server) throws org.apache.thrift.TException
org.apache.thrift.TException
public Set<TServerInstance> getCurrentServers()
public int size()
public TServerInstance find(String serverName)
public boolean isOnline(String serverName)
public void remove(TServerInstance server)
Copyright © 2011-2015 The Apache Software Foundation. All Rights Reserved.