Package org.apache.accumulo.fate.zookeeper

Examples of org.apache.accumulo.fate.zookeeper.ZooCache

105
106
107
108
109
110
111
112
113
114
115
116
    return tableId == null ? "(NAME:" + tableName + ")" : tableId;
  }
 
  public static TableState getTableState(Instance instance, String tableId) {
    String statePath = ZooUtil.getRoot(instance) + Constants.ZTABLES + "/" + tableId + Constants.ZTABLE_STATE;
    ZooCache zc = getZooCache(instance);
    byte[] state = zc.get(statePath);
    if (state == null)
      return TableState.UNKNOWN;
   
    return TableState.valueOf(new String(state, Constants.UTF8));
  }
View Full Code Here
44
45
46
47
48
49
50
51
52
53
54
55
public class ServerClient {
  private static final Logger log = Logger.getLogger(ServerClient.class);
  private static final Map<String,ZooCache> zooCaches = new HashMap<String,ZooCache>();
 
  private synchronized static ZooCache getZooCache(Instance instance) {
    ZooCache result = zooCaches.get(instance.getZooKeepers());
    if (result == null) {
      result = new ZooCache(instance.getZooKeepers(), instance.getZooKeepersSessionTimeOut(), null);
      zooCaches.put(instance.getZooKeepers(), result);
    }
    return result;
  }
View Full Code Here
133
134
135
136
137
138
139
140
141
142
143
144
145
    // create list of servers
    ArrayList<ThriftTransportKey> servers = new ArrayList<ThriftTransportKey>();
   
    // add tservers
   
    ZooCache zc = getZooCache(instance);
    AccumuloConfiguration conf = instance.getConfiguration();
    for (String tserver : zc.getChildren(ZooUtil.getRoot(instance) + Constants.ZTSERVERS)) {
      String path = ZooUtil.getRoot(instance) + Constants.ZTSERVERS + "/" + tserver;
      byte[] data = ZooUtil.getLockData(zc, path);
      if (data != null && !new String(data).equals("master"))
        servers.add(new ThriftTransportKey(
            new ServerServices(new String(data)).getAddressString(Service.TSERV_CLIENT),
View Full Code Here
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
    }
    return ZooCache.getInstance(instance.getZooKeepers(), instance.getZooKeepersSessionTimeOut());
  }
 
  private static SortedMap<String,String> getMap(Instance instance, boolean nameAsKey) {
    ZooCache zc = getZooCache(instance);
   
    List<String> tableIds = zc.getChildren(ZooUtil.getRoot(instance) + Constants.ZTABLES);
   
    TreeMap<String,String> tableMap = new TreeMap<String,String>();
   
    for (String tableId : tableIds) {
      byte[] tblPath = zc.get(ZooUtil.getRoot(instance) + Constants.ZTABLES + "/" + tableId + Constants.ZTABLE_NAME);
      if (tblPath != null) {
        if (nameAsKey)
          tableMap.put(new String(tblPath), tableId);
        else
          tableMap.put(tableId, new String(tblPath));
View Full Code Here
81
82
83
84
85
86
87
88
89
  public static SortedMap<String,String> getIdToNameMap(Instance instance) {
    return getMap(instance, false);
  }
 
  public static boolean exists(Instance instance, String tableId) {
    ZooCache zc = getZooCache(instance);
    List<String> tableIds = zc.getChildren(ZooUtil.getRoot(instance) + Constants.ZTABLES);
    return tableIds.contains(tableId);
  }
View Full Code Here
102
103
104
105
106
107
108
109
110
111
112
113
    return tableId == null ? "(NAME:" + tableName + ")" : tableId;
  }
 
  public static TableState getTableState(Instance instance, String tableId) {
    String statePath = ZooUtil.getRoot(instance) + Constants.ZTABLES + "/" + tableId + Constants.ZTABLE_STATE;
    ZooCache zc = getZooCache(instance);
    byte[] state = zc.get(statePath);
    if (state == null)
      return TableState.UNKNOWN;
   
    return TableState.valueOf(new String(state));
  }
View Full Code Here
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
   * @see org.apache.accumulo.core.client.admin.InstanceOperations#getTabletServers()
   */
 
  @Override
  public List<String> getTabletServers() {
    ZooCache cache = ZooCache.getInstance(instance.getZooKeepers(), instance.getZooKeepersSessionTimeOut());
    String path = ZooUtil.getRoot(instance) + Constants.ZTSERVERS;
    List<String> results = new ArrayList<String>();
    for (String candidate : cache.getChildren(path)) {
      List<String> children = cache.getChildren(path + "/" + candidate);
      if (children != null && children.size() > 0) {
        List<String> copy = new ArrayList<String>(children);
        Collections.sort(copy);
        byte[] data = cache.get(path + "/" + candidate + "/" + copy.get(0));
        if (data != null && !"master".equals(new String(data, Constants.UTF8))) {
          results.add(candidate);
        }
      }
    }
View Full Code Here
48
49
50
51
52
53
54
55
56
57
58
    this.parent = parent;
  }
 
  synchronized public static ZooConfiguration getInstance(Instance inst, AccumuloConfiguration parent) {
    if (instance == null) {
      propCache = new ZooCache(inst.getZooKeepers(), inst.getZooKeepersSessionTimeOut());
      instance = new ZooConfiguration(parent);
      instanceId = inst.getInstanceID();
    }
    return instance;
  }
View Full Code Here
57
58
59
60
61
62
63
64
65
66
67
    return instance;
  }
 
  synchronized public static ZooConfiguration getInstance(AccumuloConfiguration parent) {
    if (instance == null) {
      propCache = new ZooCache(parent.get(Property.INSTANCE_ZK_HOST), (int) parent.getTimeInMillis(Property.INSTANCE_ZK_TIMEOUT));
      instance = new ZooConfiguration(parent);
      @SuppressWarnings("deprecation")
      String deprecatedInstanceIdFromHdfs = ZooKeeperInstance.getInstanceIDFromHdfs(ServerConstants.getInstanceIdLocation());
      instanceId = deprecatedInstanceIdFromHdfs;
    }
View Full Code Here
61
62
63
64
65
66
67
68
69
  private static ZooCache getTablePropCache() {
    Instance inst = HdfsZooInstance.getInstance();
    if (tablePropCache == null)
      synchronized (TableConfiguration.class) {
        if (tablePropCache == null)
          tablePropCache = new ZooCache(inst.getZooKeepers(), inst.getZooKeepersSessionTimeOut(), new TableConfWatcher(inst));
      }
    return tablePropCache;
  }
View Full Code Here
TOP

Related Classes of org.apache.accumulo.fate.zookeeper.ZooCache

  • org.apache.accumulo.core.client.admin.InstanceOperationsImpl
  • org.apache.accumulo.core.client.impl.InstanceOperationsImpl
  • org.apache.accumulo.core.client.impl.Namespaces
  • org.apache.accumulo.core.client.impl.RootTabletLocator
  • org.apache.accumulo.core.client.impl.ServerClient
  • org.apache.accumulo.core.client.impl.Tables
  • org.apache.accumulo.server.client.HdfsZooInstance
  • org.apache.accumulo.server.conf.NamespaceConfiguration
  • org.apache.accumulo.server.conf.TableConfiguration
  • org.apache.accumulo.server.conf.ZooConfiguration
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.