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

ZkUtil.connect介绍

暂无

代码示例

代码示例来源：origin: NGDATA/lilyproject

public LilyClient(String zookeeperConnectString, int sessionTimeout, boolean keepAlive) throws IOException, InterruptedException,
    KeeperException, ZkConnectException, NoServersException, RepositoryException {
  this(ZkUtil.connect(zookeeperConnectString, sessionTimeout), keepAlive);
  managedZk = true;
}

代码示例来源：origin: NGDATA/lilyproject

@Override
public void run() {
  try {
    ZooKeeperItf zk = ZkUtil.connect("localhost:2181,localhost:21812", 5000);
    new LeaderElection(zk, "electiontest", "/lily/electiontest/leaders", new Callback());
  } catch (Exception e) {
    e.printStackTrace();
  }
}

代码示例来源：origin: NGDATA/lilyproject

/**
 * Factory method for creation of a {@code BulkIngester} that operates on a non-default repository table.
 *
 * @param zkConnString connection string for ZooKeeper
 * @param timeout      ZooKeeper session timeout
 * @param tableName    name of the repository table to write to
 */
public static BulkIngester newBulkIngester(String zkConnString, int timeout, String repositoryName, String tableName,
                      boolean bulkMode) {
  try {
    ZooKeeperItf zk = ZkUtil.connect(zkConnString, timeout);
    // we need a lily client for non bulk access
    LilyClient lilyClient = new LilyClient(zk);
    // we need an HBaseRepository for bulk access
    Configuration conf = HBaseConfiguration.create();
    conf.set("hbase.zookeeper.quorum", zkConnString);
    HBaseTableFactory hbaseTableFactory = new HBaseTableFactoryImpl(conf);
    HBaseRepository hbaseRepository = createHBaseRepository(repositoryName, tableName, zk, conf, hbaseTableFactory);
    return new BulkIngester(
        lilyClient,
        hbaseRepository,
        LilyHBaseSchema.getRecordTable(hbaseTableFactory, hbaseRepository.getRepositoryName(),
            hbaseRepository.getTableName()),
        bulkMode);
  } catch (Exception e) {
    ExceptionUtil.handleInterrupt(e);
    throw new RuntimeException(e);
  }
}

代码示例来源：origin: NGDATA/lilyproject

private Server createServer() throws Exception {
  if (this.useSolrCloud) {
    // create path on zookeeper for solr cloud
    ZooKeeperItf zk = ZkUtil.connect("localhost:2181", 10000);
    ZkUtil.createPath(zk, "/solr");
    zk.close();
  }
  Server server = new Server(solrPort);
  WebAppContext ctx = new WebAppContext(solrWarPath, "/solr");
  // The reason to change the classloading behavior was primarily so that the logging libraries would
  // be inherited, and hence that Solr would use the same logging system & conf.
  ctx.setParentLoaderPriority(true);
  server.addHandler(ctx);
  return server;
}

代码示例来源：origin: NGDATA/lilyproject

public void setupCore() throws Exception {
  if (coreSetup) {
    return;
  }
  hbaseProxy = new HBaseProxy();
  hbaseProxy.start();
  hadoopConf = hbaseProxy.getConf();
  zk = ZkUtil.connect(hbaseProxy.getZkConnectString(), 10000);
  hbaseTableFactory = new HBaseTableFactoryImpl(hadoopConf);
  repositoryModel = new RepositoryModelImpl(zk);
  repositoryMaster = new RepositoryMaster(zk, repositoryModel, new DummyLilyInfo(),
      Collections.<RepositoryMasterHook>singletonList(new CoreRepositoryMasterHook(hbaseTableFactory, hbaseProxy.getConf())));
  repositoryMaster.start();
  coreSetup = true;
}