import org.apache.mesos.state.ZooKeeperState; //导入依赖的package包/类
/**
 * Constructor for State
 *
 * @param zookeeperUrl the URL of the Zookeeper
 */
public State(String zookeeperUrl) {
    Matcher matcher = validateZookeeperUrl(zookeeperUrl);
    state = new ZooKeeperState(
            matcher.group(1),
            30000,
            TimeUnit.MILLISECONDS,
            "/" + SchedulerConfiguration.getFrameworkName() + matcher.group(2));
}
 

import org.apache.mesos.state.ZooKeeperState; //导入依赖的package包/类
public PersistentStateStore(ZooKeeperState zk, int desiredInstances) {
    this.zk = zk;
    this.zkFuture = zk.fetch(CRATE_STATE);
    this.state = restore();
    int nodeCount = state.desiredInstances().getValue() == CrateState.UNDEFINED_DESIRED_INSTANCES ?
            desiredInstances :
            state.desiredInstances().getValue();
    desiredInstances(nodeCount);
}
 

import org.apache.mesos.state.ZooKeeperState; //导入依赖的package包/类
@Autowired
public PersistentState(LogstashSettings logstashSettings) {

  if (logstashSettings.getNativeLibrary() != null) {
    MesosNativeLibrary.load(logstashSettings.getNativeLibrary());
  }

  this.zkState = new ZooKeeperState(logstashSettings.getStateZkServers(),
    logstashSettings.getStateZkTimeout(),
    TimeUnit.MILLISECONDS,
    "/logstash-mesos/" + logstashSettings.getFrameworkName());
}
 

import org.apache.mesos.state.ZooKeeperState; //导入依赖的package包/类
@Inject
public HBaseZkStore(HBaseFrameworkConfig hbaseFrameworkConfig) {

  this.state = new ZooKeeperState(hbaseFrameworkConfig.getStateZkServers(),
      hbaseFrameworkConfig.getStateZkTimeout(),
      TimeUnit.MILLISECONDS,
      "/hbase-mesos/" + hbaseFrameworkConfig.getFrameworkName());
}
 

import org.apache.mesos.state.ZooKeeperState; //导入依赖的package包/类
@Provides
@Singleton
State providesStateStore(MyriadConfiguration cfg) {
  return new ZooKeeperState(cfg.getZkServers(), cfg.getZkTimeout(), TimeUnit.MILLISECONDS, "/myriad/" + cfg.getFrameworkName());
}