本文整理了Java中org.apache.accumulo.server.zookeeper.ZooCache.<init>()
方法的一些代码示例,展示了ZooCache.<init>()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooCache.<init>()
方法的具体详情如下:
包路径:org.apache.accumulo.server.zookeeper.ZooCache
类名称:ZooCache
方法名:<init>
暂无
代码示例来源:origin: org.apache.accumulo/accumulo-server-base
public synchronized ZooCache getZooCache() {
if (zooCache == null)
zooCache = new ZooCache(this);
return zooCache;
}
代码示例来源:origin: org.apache.accumulo/accumulo-server-base
public ZKAuthorizor() {
zooCache = new ZooCache();
}
代码示例来源:origin: org.apache.accumulo/accumulo-server
public synchronized ZooCache getZooCache() {
if (zooCache == null)
zooCache = new ZooCache(this);
return zooCache;
}
代码示例来源:origin: org.apache.accumulo/accumulo-server-base
public ZKAuthenticator() {
zooCache = new ZooCache();
}
代码示例来源:origin: org.apache.accumulo/accumulo-server
public ZKPermHandler() {
zooCache = new ZooCache();
}
代码示例来源:origin: org.apache.accumulo/accumulo-server
public ZKAuthenticator() {
zooCache = new ZooCache();
}
代码示例来源:origin: org.apache.accumulo/accumulo-server
public ZKAuthorizor() {
zooCache = new ZooCache();
}
代码示例来源:origin: org.apache.accumulo/accumulo-server-base
public ZKPermHandler() {
zooCache = new ZooCache();
}
代码示例来源:origin: org.apache.accumulo/accumulo-server
/**
*
* @deprecated not for client use
*/
@Deprecated
public SecurityOperation(String instanceId) {
ZKUserPath = Constants.ZROOT + "/" + instanceId + "/users";
zooCache = new ZooCache();
}
代码示例来源:origin: org.apache.accumulo/accumulo-server-base
public KerberosAuthenticator() {
this(new ZooCache(), SiteConfiguration.getInstance());
}
代码示例来源:origin: org.apache.accumulo/accumulo-server-base
public ReplicationUtil(AccumuloServerContext context) {
this(context, new ZooCache(), new ReplicaSystemFactory());
}
代码示例来源:origin: org.apache.accumulo/accumulo-server-base
public ZooLock(String path) {
super(new ZooCache(), ZooReaderWriter.getInstance(), path);
}
代码示例来源:origin: org.apache.accumulo/accumulo-server
public ZooLock(String path) {
super(new ZooCache(), ZooReaderWriter.getInstance(), path);
}
代码示例来源:origin: org.apache.accumulo/accumulo-server-base
protected SecurityOperation(AccumuloServerContext context) {
this.context = context;
ZKUserPath = Constants.ZROOT + "/" + context.getInstance().getInstanceID() + "/users";
zooCache = new ZooCache();
}
代码示例来源:origin: org.apache.accumulo/accumulo-server
public RecoveryManager(Master master) {
this.master = master;
executor = Executors.newScheduledThreadPool(4, new NamingThreadFactory("Walog sort starter "));
zooCache = new ZooCache();
try {
List<String> workIDs = new DistributedWorkQueue(ZooUtil.getRoot(master.getInstance()) + Constants.ZRECOVERY).getWorkQueued();
sortsQueued.addAll(workIDs);
} catch (Exception e) {
log.warn(e, e);
}
}
代码示例来源:origin: org.apache.accumulo/accumulo-master
public RecoveryManager(Master master) {
this.master = master;
executor = Executors.newScheduledThreadPool(4, new NamingThreadFactory("Walog sort starter "));
zooCache = new ZooCache();
try {
AccumuloConfiguration aconf = master.getConfiguration();
List<String> workIDs = new DistributedWorkQueue(
ZooUtil.getRoot(master.getInstance()) + Constants.ZRECOVERY, aconf).getWorkQueued();
sortsQueued.addAll(workIDs);
} catch (Exception e) {
log.warn("{}", e.getMessage(), e);
}
}
代码示例来源:origin: org.apache.accumulo/accumulo-server-base
private TableManager() {
instance = HdfsZooInstance.getInstance();
zooStateCache = new ZooCache(new TableStateWatcher());
updateTableStateCache();
}
代码示例来源:origin: org.apache.accumulo/accumulo-server
private TableManager() {
instance = HdfsZooInstance.getInstance();
zooStateCache = new ZooCache(new TableStateWatcher());
updateTableStateCache();
}
代码示例来源:origin: org.apache.accumulo/accumulo-master
@Override
public void assignWork() {
if (null == workQueue) {
initializeWorkQueue(conf);
}
initializeQueuedWork();
if (null == zooCache) {
zooCache = new ZooCache();
}
// Get the maximum number of entries we want to queue work for (or the default)
this.maxQueueSize = conf.getCount(Property.REPLICATION_MAX_WORK_QUEUE);
// Scan over the work records, adding the work to the queue
createWork();
// Keep the state of the work we queued correct
cleanupFinishedWork();
}
代码示例来源:origin: org.apache.accumulo/accumulo-server
zooCache = new ZooCache();
内容来源于网络,如有侵权,请联系作者删除!