org.apache.giraph.zk.ZookeeperConfig.setDataDir()方法的使用及代码示例

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

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

ZookeeperConfig.setDataDir介绍

[英]Set snapshot log dir
[中]设置快照日志目录

代码示例

代码示例来源:origin: org.apache.giraph/giraph-core

/**
 * Configuration options for running local ZK.
 *
 * @param zkDir directory for ZK to hold files in.
 * @return zookeeper configuration object
 */
private static ZookeeperConfig configLocalZooKeeper(File zkDir) {
 ZookeeperConfig config = new ZookeeperConfig();
 config.setMaxSessionTimeout(100000);
 config.setMinSessionTimeout(10000);
 config.setClientPortAddress(new InetSocketAddress("localhost", 0));
 config.setDataDir(zkDir.getAbsolutePath());
 return config;
}

代码示例来源:origin: rayokota/hgraphdb

/**
 * Configuration options for running local ZK.
 *
 * @param zkDir directory for ZK to hold files in.
 * @return zookeeper configuration object
 */
private static ZookeeperConfig configLocalZooKeeper(File zkDir) {
  ZookeeperConfig config = new ZookeeperConfig();
  config.setMaxSessionTimeout(100000);
  config.setMinSessionTimeout(10000);
  config.setClientPortAddress(new InetSocketAddress("localhost", 0));
  config.setDataDir(zkDir.getAbsolutePath());
  return config;
}

代码示例来源:origin: org.apache.giraph/giraph-core

/**
 * Whoever is elected to be a ZooKeeper server must generate a config file
 * locally.
 *
 */
private void generateZooKeeperConfig() {
 if (LOG.isInfoEnabled()) {
  LOG.info("generateZooKeeperConfig: with base port " +
    zkBasePort);
 }
 File zkDirFile = new File(this.zkDir);
 boolean mkDirRet = zkDirFile.mkdirs();
 if (LOG.isInfoEnabled()) {
  LOG.info("generateZooKeeperConfigFile: Make directory of " +
    zkDirFile.getName() + " = " + mkDirRet);
 }
 /** Set zookeeper system properties */
 System.setProperty("zookeeper.snapCount",
   Integer.toString(GiraphConstants.DEFAULT_ZOOKEEPER_SNAP_COUNT));
 System.setProperty("zookeeper.forceSync",
   GiraphConstants.ZOOKEEPER_FORCE_SYNC.get(conf) ? "yes" : "no");
 System.setProperty("zookeeper.skipACL",
   GiraphConstants.ZOOKEEPER_SKIP_ACL.get(conf) ? "yes" : "no");
 config.setDataDir(zkDir);
 config.setDataLogDir(zkDir);
 config.setClientPortAddress(new InetSocketAddress(zkBasePort));
 config.setMinSessionTimeout(conf.getZooKeeperMinSessionTimeout());
 config.setMaxSessionTimeout(conf.getZooKeeperMaxSessionTimeout());
}

相关文章