Package org.apache.accumulo.fate.zookeeper

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

61
62
63
64
65
66
67
    }
  }

  private HdfsZooInstance() {
    AccumuloConfiguration acuConf = ServerConfiguration.getSiteConfiguration();
    zooCache = new ZooCache(acuConf.get(Property.INSTANCE_ZK_HOST), (int) acuConf.getTimeInMillis(Property.INSTANCE_ZK_TIMEOUT));
  }
View Full Code Here
46
47
48
49
50
51
52
53
54
55
56
    Instance instance = HdfsZooInstance.getInstance();
    String tserverPath = ZooUtil.getRoot(instance) + Constants.ZTSERVERS;
    Opts opts = new Opts();
    opts.parseArgs(TabletServerLocks.class.getName(), args);
   
    ZooCache cache = new ZooCache(instance.getZooKeepers(), instance.getZooKeepersSessionTimeOut());
   
    if (opts.list) {
      IZooReaderWriter zoo = ZooReaderWriter.getInstance();
     
      List<String> tabletServers = zoo.getChildren(tserverPath);
View Full Code Here
65
66
67
68
69
70
71
    }
  }

  private HdfsZooInstance() {
    AccumuloConfiguration acuConf = ServerConfiguration.getSiteConfiguration();
    zooCache = new ZooCache(acuConf.get(Property.INSTANCE_ZK_HOST), (int) acuConf.getTimeInMillis(Property.INSTANCE_ZK_TIMEOUT));
  }
View Full Code Here
85
86
87
88
89
90
91
92
93
  @Override
  public void invalidateCache(Collection<KeyExtent> keySet) {}
 
  @Override
  public void invalidateCache(String server) {
    ZooCache zooCache = ZooCache.getInstance(instance.getZooKeepers(), instance.getZooKeepersSessionTimeOut());
    String root = ZooUtil.getRoot(instance) + Constants.ZTSERVERS;
    zooCache.clear(root + "/" + server);
  }
View Full Code Here
95
96
97
98
99
100
101
102
103
104
105
106
107
108
  @Override
  public void invalidateCache() {}
 
  protected TabletLocation getRootTabletLocation() {
    String zRootLocPath = ZooUtil.getRoot(instance) + RootTable.ZROOT_TABLET_LOCATION;
    ZooCache zooCache = ZooCache.getInstance(instance.getZooKeepers(), instance.getZooKeepersSessionTimeOut());
   
    OpTimer opTimer = new OpTimer(Logger.getLogger(this.getClass()), Level.TRACE).start("Looking up root tablet location in zookeeper.");
    byte[] loc = zooCache.get(zRootLocPath);
    opTimer.stop("Found root tablet at " + (loc == null ? null : new String(loc)) + " in %DURATION%");
   
    if (loc == null) {
      return null;
    }
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);
      // InstanceID should be the same across all volumes, so just choose one
      VolumeManager fs;
      try {
        fs = VolumeManagerImpl.get();
View Full Code Here
61
62
63
64
65
66
67
68
69
  }

  private void initializeZooCache() {
    synchronized (initLock) {
      if (null == tablePropCache) {
        tablePropCache = new ZooCache(instance.getZooKeepers(), instance.getZooKeepersSessionTimeOut(), new TableConfWatcher(instance));
      }
    }
  }
View Full Code Here
136
137
138
139
140
141
142
143
144
145
146
147
148
  @Override
  public void getProperties(Map<String,String> props, PropertyFilter filter) {
    parent.getProperties(props, filter);

    ZooCache zc = getTablePropCache();

    List<String> children = zc.getChildren(ZooUtil.getRoot(instanceId) + Constants.ZTABLES + "/" + table + Constants.ZTABLE_CONF);
    if (children != null) {
      for (String child : children) {
        if (child != null && filter.accept(child)) {
          String value = get(zc, child);
          if (value != null)
View Full Code Here
81
82
83
84
85
86
87
88
  }

  private void initializePropCache() {
    synchronized (lock) {
      if (propCache == null)
        propCache = new ZooCache(inst.getZooKeepers(), inst.getZooKeepersSessionTimeOut(), new NamespaceConfWatcher(inst));
    }
  }
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.