本文整理了Java中org.apache.giraph.zk.ZookeeperConfig.setClientPortAddress()
方法的一些代码示例,展示了ZookeeperConfig.setClientPortAddress()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZookeeperConfig.setClientPortAddress()
方法的具体详情如下:
包路径:org.apache.giraph.zk.ZookeeperConfig
类名称:ZookeeperConfig
方法名:setClientPortAddress
[英]Set zookeeper server address
[中]设置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: 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());
}
内容来源于网络,如有侵权,请联系作者删除!