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

ZookeeperConfig介绍

[英]Zookeeper configuration file. Originally copied from zookeeper sources to allow modification on the fly instead of reading from disk.
[中]Zookeeper配置文件。最初是从zookeeper源代码复制的，以允许动态修改，而不是从磁盘读取。

代码示例

代码示例来源：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: 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());
}

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

/**
 * Run from a ServerConfig.
 * @param config ServerConfig to use.
 * @throws IOException
 */
public void runFromConfig(ZookeeperConfig config) throws IOException {
 LOG.info("Starting server");
 try {
  // Note that this thread isn't going to be doing anything else,
  // so rather than spawning another thread, we will just call
  // run() in this thread.
  // create a file logger url from the command line args
  zkServer = new ZooKeeperServer();
  FileTxnSnapLog ftxn = new FileTxnSnapLog(new
    File(config.getDataLogDir()), new File(config.getDataDir()));
  zkServer.setTxnLogFactory(ftxn);
  zkServer.setTickTime(GiraphConstants.DEFAULT_ZOOKEEPER_TICK_TIME);
  zkServer.setMinSessionTimeout(config.getMinSessionTimeout());
  zkServer.setMaxSessionTimeout(config.getMaxSessionTimeout());
  cnxnFactory = ServerCnxnFactory.createFactory();
  cnxnFactory.configure(config.getClientPortAddress(),
    GiraphConstants.DEFAULT_ZOOKEEPER_MAX_CLIENT_CNXNS);
  cnxnFactory.startup(zkServer);
 } catch (InterruptedException e) {
  // warn, but generally this is ok
  LOG.warn("Server interrupted", e);
 }
}

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

/**
 * Starts quorum and/or zookeeper service.
 * @param config quorum and zookeeper configuration
 * @return zookeeper port
 * @throws IOException if can't start zookeeper
 */
public int start(ZookeeperConfig config) throws IOException {
 serverRunner = new ZooKeeperServerRunner();
 //Make sure zookeeper starts first and purge manager last
 //This is important because zookeeper creates a folder
 //strucutre on the local disk. Purge manager also tries
 //to create it but from a different thread and can run into
 //race condition. See FileTxnSnapLog source code for details.
 int port = serverRunner.start(config);
 // Start and schedule the the purge task
 DatadirCleanupManager purgeMgr = new DatadirCleanupManager(
   config
     .getDataDir(), config.getDataLogDir(),
   GiraphConstants.ZOOKEEPER_SNAP_RETAIN_COUNT,
   GiraphConstants.ZOOKEEPER_PURGE_INTERVAL);
 purgeMgr.start();
 return port;
}

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

config = new ZookeeperConfig();
zkBasePort = GiraphConstants.ZOOKEEPER_SERVER_PORT.get(conf);

代码示例来源：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;
}