本文整理了Java中com.addthis.hydra.job.store.ZookeeperDataStore.<init>()
方法的一些代码示例,展示了ZookeeperDataStore.<init>()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZookeeperDataStore.<init>()
方法的具体详情如下:
包路径:com.addthis.hydra.job.store.ZookeeperDataStore
类名称:ZookeeperDataStore
方法名:<init>
暂无
代码示例来源:origin: addthis/hydra
public static SpawnDataStore makeSpawnDataStore(DataStoreType type) throws Exception {
Properties properties = new Properties();
if (sqlUser != null) {
properties.put("user", sqlUser);
properties.put("password", sqlPassword);
}
switch (type) {
case FS: return new FilesystemDataStore(new File(fsDataStoreFileRoot));
case ZK: return new ZookeeperDataStore(null);
case MYSQL:
return new MysqlDataStore("jdbc:mysql:thin://" + sqlHostName + ":" + sqlPort + "/", sqlDbName, sqlTableName, properties);
case POSTGRES:
return new PostgresDataStore("jdbc:postgres://" + sqlHostName + ":" + sqlPort + "/", sqlDbName, sqlTableName, properties);
default: throw new IllegalArgumentException("Unexpected DataStoreType " + type);
}
}
代码示例来源:origin: addthis/hydra
@Before
public void createSpawnDataStore() {
spawnDataStore = new ZookeeperDataStore(zkClient);
}
代码示例来源:origin: addthis/hydra
@Before
public void setUp() throws Exception {
spawnDataStore = new ZookeeperDataStore(zkClient);
jcm = setUpSampleState();
qcw = new QueryConfigWatcher(spawnDataStore);
}
内容来源于网络,如有侵权,请联系作者删除!