本文整理了Java中com.ucar.datalink.common.zookeeper.ZkConfig
类的一些代码示例,展示了ZkConfig
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZkConfig
类的具体详情如下:
包路径:com.ucar.datalink.common.zookeeper.ZkConfig
类名称:ZkConfig
[英]Created by lubiao on 2016/12/8.
[中]卢彪于2016年12月8日创作。
代码示例来源:origin: ucarGroup/DataLink
@Override
public ZkClientX load(ZkConfig key) throws Exception {
return new ZkClientX(key.getZkServers(), key.getSessionTimeout(), key.getConnectionTimeout());
}
}
代码示例来源:origin: ucarGroup/DataLink
private Configuration initHbaseConf() {
Configuration config = new Configuration();
config.set(HConstants.ZOOKEEPER_QUORUM, replicationConfig.getZkConfig().parseServersToString());
config.setInt(HConstants.ZOOKEEPER_CLIENT_PORT, replicationConfig.getZkConfig().parsePort());
config.set(HConstants.ZOOKEEPER_ZNODE_PARENT, replicationConfig.getZnodeParent());
config.setInt(HConstants.REGION_SERVER_HANDLER_COUNT, replicationConfig.getHandlers());
config.setInt("hbase.ipc.server.read.threadpool.size", 2);
return config;
}
代码示例来源:origin: ucarGroup/DataLink
DLinkZkUtils.init(new ZkConfig(
config.getString(WorkerConfig.ZK_SERVER_CONFIG),
config.getInt(WorkerConfig.ZK_SESSION_TIMEOUT_MS_CONFIG),
代码示例来源:origin: ucarGroup/DataLink
private ReplicationConfig buidReplicationConfig(HBaseReaderParameter readerParameter) {
ReplicationConfig config = new ReplicationConfig();
config.setHbaseName("hbase-4-datalink");
config.setZnodeParent(readerParameter.getReplZnodeParent());
ZkMediaSrcParameter zkMediaSrcParameter = DataLinkFactory.getObject(MediaSourceService.class).
getById(readerParameter.getReplZkMediaSourceId()).getParameterObj();
config.setZkConfig(new ZkConfig(zkMediaSrcParameter.getServers(), 6000, 60000));
return config;
}
}
代码示例来源:origin: ucarGroup/DataLink
public void init(Properties props) {
this.config = ManagerConfig.fromProps(props, true);
this.zkUtils = DLinkZkUtils.init(new ZkConfig(config.getZkServer(), config.getZkSessionTimeoutMs(), config.getZkConnectionTimeoutMs()), config.getZkRoot());
this.serverStatusMonitor = new ServerStatusMonitor(config, zkUtils);
this.serverStatusMonitor.setListener(new ServerStatusListener() {
@Override
public void onActiveChange() {
//只要发生Manager-Active-Change,不管本机是否是新的Manager,都把Group信息清除
groupCoordinator.clearGroupMetaInfo();
scheduleServer.onActiveChange();
}
});
this.groupCoordinator = new GroupCoordinator(config, zkUtils, serverStatusMonitor);
this.nettyServer = new NettyServer(this.config, this.groupCoordinator);
this.jettyServer = new JettyServer(config);
this.monitorManager = new MonitorManager();
this.scheduleServer = new ScheduleServer(serverStatusMonitor);
logger.info("ServerContainer is initialized.");
}
内容来源于网络,如有侵权,请联系作者删除!