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

ZooKeeperUtils.startCuratorFramework介绍

[英]Starts a CuratorFramework instance and connects it to the given ZooKeeper quorum.
[中]启动CuratorFramework实例并将其连接到给定的ZooKeeper仲裁。

代码示例

代码示例来源：origin: com.alibaba.blink/flink-runtime

public static HighAvailabilityServices createAvailableOrEmbeddedServices(
  Configuration config,
  Executor executor) throws Exception {
  HighAvailabilityMode highAvailabilityMode = LeaderRetrievalUtils.getRecoveryMode(config);
  switch (highAvailabilityMode) {
    case NONE:
      return new EmbeddedHaServices(executor);
    case FILESYSTEM:
      throw new UnsupportedOperationException("to be implemented");
    case ZOOKEEPER:
      BlobStoreService blobStoreService = BlobUtils.createBlobStoreFromConfig(config);
      return new ZooKeeperHaServices(
        ZooKeeperUtils.startCuratorFramework(config),
        executor,
        config,
        blobStoreService);
    default:
      throw new Exception("High availability mode " + highAvailabilityMode + " is not supported.");
  }
}

代码示例来源：origin: org.apache.flink/flink-runtime_2.10

public static HighAvailabilityServices createAvailableOrEmbeddedServices(
  Configuration config,
  Executor executor) throws Exception {
  HighAvailabilityMode highAvailabilityMode = LeaderRetrievalUtils.getRecoveryMode(config);
  switch (highAvailabilityMode) {
    case NONE:
      return new EmbeddedHaServices(executor);
    case ZOOKEEPER:
      BlobStoreService blobStoreService = BlobUtils.createBlobStoreFromConfig(config);
      return new ZooKeeperHaServices(
        ZooKeeperUtils.startCuratorFramework(config),
        executor,
        config,
        blobStoreService);
    default:
      throw new Exception("High availability mode " + highAvailabilityMode + " is not supported.");
  }
}

代码示例来源：origin: org.apache.flink/flink-runtime

public static HighAvailabilityServices createAvailableOrEmbeddedServices(
  Configuration config,
  Executor executor) throws Exception {
  HighAvailabilityMode highAvailabilityMode = LeaderRetrievalUtils.getRecoveryMode(config);
  switch (highAvailabilityMode) {
    case NONE:
      return new EmbeddedHaServices(executor);
    case ZOOKEEPER:
      BlobStoreService blobStoreService = BlobUtils.createBlobStoreFromConfig(config);
      return new ZooKeeperHaServices(
        ZooKeeperUtils.startCuratorFramework(config),
        executor,
        config,
        blobStoreService);
    case FACTORY_CLASS:
      return createCustomHAServices(config, executor);
    default:
      throw new Exception("High availability mode " + highAvailabilityMode + " is not supported.");
  }
}

代码示例来源：origin: org.apache.flink/flink-runtime_2.11

public static HighAvailabilityServices createAvailableOrEmbeddedServices(
  Configuration config,
  Executor executor) throws Exception {
  HighAvailabilityMode highAvailabilityMode = LeaderRetrievalUtils.getRecoveryMode(config);
  switch (highAvailabilityMode) {
    case NONE:
      return new EmbeddedHaServices(executor);
    case ZOOKEEPER:
      BlobStoreService blobStoreService = BlobUtils.createBlobStoreFromConfig(config);
      return new ZooKeeperHaServices(
        ZooKeeperUtils.startCuratorFramework(config),
        executor,
        config,
        blobStoreService);
    case FACTORY_CLASS:
      return createCustomHAServices(config, executor);
    default:
      throw new Exception("High availability mode " + highAvailabilityMode + " is not supported.");
  }
}

代码示例来源：origin: org.apache.flink/flink-runtime

public ZooKeeperUtilityFactory(Configuration configuration, String path) throws Exception {
  Preconditions.checkNotNull(path, "path");
  root = ZooKeeperUtils.startCuratorFramework(configuration);
  root.newNamespaceAwareEnsurePath(path).ensure(root.getZookeeperClient());
  facade = root.usingNamespace(ZooKeeperUtils.generateZookeeperPath(root.getNamespace(), path));
}

代码示例来源：origin: com.alibaba.blink/flink-runtime

public ZooKeeperUtilityFactory(Configuration configuration, String path) throws Exception {
  Preconditions.checkNotNull(path, "path");
  root = ZooKeeperUtils.startCuratorFramework(configuration);
  root.newNamespaceAwareEnsurePath(path).ensure(root.getZookeeperClient());
  facade = root.usingNamespace(ZooKeeperUtils.generateZookeeperPath(root.getNamespace(), path));
}

代码示例来源：origin: org.apache.flink/flink-runtime_2.10

public ZooKeeperUtilityFactory(Configuration configuration, String path) throws Exception {
  Preconditions.checkNotNull(path, "path");
  root = ZooKeeperUtils.startCuratorFramework(configuration);
  root.newNamespaceAwareEnsurePath(path).ensure(root.getZookeeperClient());
  facade = root.usingNamespace(ZooKeeperUtils.generateZookeeperPath(root.getNamespace(), path));
}

代码示例来源：origin: org.apache.flink/flink-runtime_2.11

public ZooKeeperUtilityFactory(Configuration configuration, String path) throws Exception {
  Preconditions.checkNotNull(path, "path");
  root = ZooKeeperUtils.startCuratorFramework(configuration);
  root.newNamespaceAwareEnsurePath(path).ensure(root.getZookeeperClient());
  facade = root.usingNamespace(ZooKeeperUtils.generateZookeeperPath(root.getNamespace(), path));
}

代码示例来源：origin: org.apache.flink/flink-runtime_2.10

ZooKeeperUtils.startCuratorFramework(configuration),
executor,
configuration,

代码示例来源：origin: com.alibaba.blink/flink-runtime

ZooKeeperUtils.startCuratorFramework(configuration),
executor,
configuration,

代码示例来源：origin: org.apache.flink/flink-runtime_2.11

ZooKeeperUtils.startCuratorFramework(configuration),
executor,
configuration,

代码示例来源：origin: org.apache.flink/flink-runtime

ZooKeeperUtils.startCuratorFramework(configuration),
executor,
configuration,