com.addthis.hydra.job.store.ZookeeperDataStore.<init>()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(1.4k)|赞(0)|评价(0)|浏览(132)

本文整理了Java中com.addthis.hydra.job.store.ZookeeperDataStore.<init>()方法的一些代码示例,展示了ZookeeperDataStore.<init>()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZookeeperDataStore.<init>()方法的具体详情如下:
包路径:com.addthis.hydra.job.store.ZookeeperDataStore
类名称:ZookeeperDataStore
方法名:<init>

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);
}

相关文章