本文整理了Java中org.apache.metron.common.zookeeper.ZKConfigurationsCache
类的一些代码示例,展示了ZKConfigurationsCache
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZKConfigurationsCache
类的具体详情如下:
包路径:org.apache.metron.common.zookeeper.ZKConfigurationsCache
类名称:ZKConfigurationsCache
暂无
代码示例来源:origin: apache/metron
@Bean(initMethod = "start", destroyMethod="close")
public ConfigurationsCache cache(CuratorFramework client) {
return new ZKConfigurationsCache( client
, ZKConfigurationsCache.ConfiguredTypes.ENRICHMENT
, ZKConfigurationsCache.ConfiguredTypes.PARSER
, ZKConfigurationsCache.ConfiguredTypes.INDEXING
);
}
代码示例来源:origin: apache/metron
public void reset() {
Lock writeLock = lock.writeLock();
try {
writeLock.lock();
close();
initializeCache(client);
}
finally{
writeLock.unlock();
}
}
代码示例来源:origin: apache/metron
@Override
public void start() {
initializeCache(client);
}
代码示例来源:origin: apache/metron
client = ConfigurationsUtils.getClient(zkComponent.getConnectionString());
client.start();
cache = new ZKConfigurationsCache(client);
cache.start();
内容来源于网络,如有侵权,请联系作者删除!