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

ZookeeperLocalCluster介绍

[英]In memory ZK cluster using Curator
[中]使用Curator的内存ZK集群

代码示例

代码示例来源：origin: sakserv/hadoop-mini-clusters

@Override
public void stop() throws Exception {
  stop(true);
}

代码示例来源：origin: com.github.sakserv/hadoop-mini-clusters-zookeeper

@Override
public void stop(boolean cleanUp) throws Exception {
  LOG.info("ZOOKEEPER: Stopping Zookeeper on port: {}", port);
  testingServer.stop();
  if (cleanUp) {
    cleanUp();
  }
}

代码示例来源：origin: sakserv/hadoop-mini-clusters

public ZookeeperLocalCluster build() {
  ZookeeperLocalCluster zookeeperLocalCluster = new ZookeeperLocalCluster(this);
  validateObject(zookeeperLocalCluster);
  return zookeeperLocalCluster;
}

代码示例来源：origin: jetoile/hadoop-unit

@Override
public Bootstrap start() {
  if (state == State.STOPPED) {
    state = State.STARTING;
    LOGGER.info("{} is starting", this.getClass().getName());
    init();
    build();
    try {
      zookeeperLocalCluster.start();
    } catch (Exception e) {
      LOGGER.error("unable to add zookeeper", e);
    }
    state = State.STARTED;
    LOGGER.info("{} is started", this.getClass().getName());
  }
  return this;
}

代码示例来源：origin: sakserv/hadoop-mini-clusters

@Override
public void stop(boolean cleanUp) throws Exception {
  LOG.info("ZOOKEEPER: Stopping Zookeeper on port: {}", port);
  testingServer.stop();
  if (cleanUp) {
    cleanUp();
  }
}

代码示例来源：origin: com.github.sakserv/hadoop-mini-clusters-zookeeper

public ZookeeperLocalCluster build() {
  ZookeeperLocalCluster zookeeperLocalCluster = new ZookeeperLocalCluster(this);
  validateObject(zookeeperLocalCluster);
  return zookeeperLocalCluster;
}

代码示例来源：origin: fr.jetoile.hadoop/hadoop-unit-zookeeper

@Override
public Bootstrap start() {
  if (state == State.STOPPED) {
    state = State.STARTING;
    LOGGER.info("{} is starting", this.getClass().getName());
    init();
    build();
    try {
      zookeeperLocalCluster.start();
    } catch (Exception e) {
      LOGGER.error("unable to add zookeeper", e);
    }
    state = State.STARTED;
    LOGGER.info("{} is started", this.getClass().getName());
  }
  return this;
}

代码示例来源：origin: com.github.sakserv/hadoop-mini-clusters-zookeeper

@Override
public void stop() throws Exception {
  stop(true);
}

代码示例来源：origin: fr.jetoile.hadoop/hadoop-unit-zookeeper

@Override
  public Bootstrap stop() {
    if (state == State.STARTED) {
      state = State.STOPPING;
      LOGGER.info("{} is stopping", this.getClass().getName());
      try {
        zookeeperLocalCluster.stop(true);
      } catch (Exception e) {
        LOGGER.error("unable to stop zookeeper", e);
      }
      state = State.STOPPED;
      LOGGER.info("{} is stopped", this.getClass().getName());
    }
    return this;
  }
}

代码示例来源：origin: jetoile/hadoop-unit

@Override
  public Bootstrap stop() {
    if (state == State.STARTED) {
      state = State.STOPPING;
      LOGGER.info("{} is stopping", this.getClass().getName());
      try {
        zookeeperLocalCluster.stop(true);
      } catch (Exception e) {
        LOGGER.error("unable to stop zookeeper", e);
      }
      state = State.STOPPED;
      LOGGER.info("{} is stopped", this.getClass().getName());
    }
    return this;
  }
}