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

ZKClusterCoordinatorDriver.getInitialEndpoints介绍

[英]Returns the set of Drillbits registered at the time of the #build()call. Should be empty for a cluster managed by YARN.
[中]返回在#build（）调用时注册的钻取数据集。对于由纱线管理的群集，应为空。

代码示例

代码示例来源：origin: apache/drill

/**
 * Called during AM startup to initialize ZK. Checks if any Drillbits are
 * already running. These are "unmanaged" because the AM could not have
 * started them (since they predate the AM.)
 */
public void start(RegistryHandler controller) {
 this.registryHandler = controller;
 try {
  zkDriver.build();
 } catch (ZKRuntimeException e) {
  LOG.error("Failed to start ZK monitoring", e);
  throw new AMWrapperException("Failed to start ZK monitoring", e);
 }
 for (DrillbitEndpoint dbe : zkDriver.getInitialEndpoints()) {
  String key = toKey(dbe);
  registry.put(key, new DrillbitTracker(key, dbe));
  // Blacklist the host for each unmanaged drillbit.
  controller.reserveHost(dbe.getAddress());
  LOG.warn("Host " + dbe.getAddress()
    + " already running a Drillbit outside of YARN.");
 }
 zkDriver.addDrillbitListener(this);
}

代码示例来源：origin: apache/drill

/**
 * Basic setup: start a ZK and verify that the initial endpoint list is empty.
 * Also validates the basics of the test setup (mock server, etc.)
 *
 * @throws Exception
 */
@Test
public void testBasics() throws Exception {
 try (TestingServer server = new TestingServer()) {
  server.start();
  String connStr = server.getConnectString();
  ZKClusterCoordinatorDriver driver = new ZKClusterCoordinatorDriver()
    .setConnect(connStr, "drill", "drillbits").build();
  assertTrue(driver.getInitialEndpoints().isEmpty());
  driver.close();
  server.stop();
 }
}

代码示例来源：origin: apache/drill

List<DrillbitEndpoint> bits = driver.getInitialEndpoints();
assertEquals(1, bits.size());
assertEquals(makeKey(FRED_HOST),