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

ZKClientService.startAndWait介绍

暂无

代码示例

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

public void start() {
  zkClient.startAndWait();
}

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

public void start() {
  zkClient.startAndWait();
  txService.startAndWait();            
}

代码示例来源：origin: cdapio/cdap

@Override
protected void startUp() {
 zkClientService.startAndWait();
}

代码示例来源：origin: com.aliyun.phoenix/ali-phoenix-core

public void start() {
  zkClient.startAndWait();
}

代码示例来源：origin: org.apache.phoenix/phoenix-core

public void start() {
  zkClient.startAndWait();
  txService.startAndWait();            
}

代码示例来源：origin: cdapio/cdap

private void startUp() throws Exception {
 zkClientService.startAndWait();
 txService.startAndWait();
}

代码示例来源：origin: org.apache.tephra/tephra-core

@Override
 public Cancellable register(Discoverable discoverable) {
  if (!zkClient.isRunning()) {
   zkClient.startAndWait();
  }
  return delegate.register(discoverable);
 }
};

代码示例来源：origin: org.apache.tephra/tephra-core

@Override
 public ServiceDiscovered discover(String s) {
  if (!zkClient.isRunning()) {
   zkClient.startAndWait();
  }
  return delegate.discover(s);
 }
};

代码示例来源：origin: caskdata/tephra

@Override
 public Cancellable register(Discoverable discoverable) {
  if (!zkClient.isRunning()) {
   zkClient.startAndWait();
  }
  return delegate.register(discoverable);
 }
};

代码示例来源：origin: co.cask.tephra/tephra-core

@Override
 public Cancellable register(Discoverable discoverable) {
  if (!zkClient.isRunning()) {
   zkClient.startAndWait();
  }
  return delegate.register(discoverable);
 }
};

代码示例来源：origin: co.cask.tephra/tephra-core

@Override
 public ServiceDiscovered discover(String s) {
  if (!zkClient.isRunning()) {
   zkClient.startAndWait();
  }
  return delegate.discover(s);
 }
};

代码示例来源：origin: caskdata/tephra

@Override
 public ServiceDiscovered discover(String s) {
  if (!zkClient.isRunning()) {
   zkClient.startAndWait();
  }
  return delegate.discover(s);
 }
};

代码示例来源：origin: cdapio/cdap

private static Context createContext(Configuration conf) throws IOException {
 // Create context needs to happen only when running in as a MapReduce job.
 // In other cases, ContextManager will be initialized using saveContext method.
 CConfiguration cConf = ConfigurationUtil.get(conf, Constants.Explore.CCONF_KEY, CConfCodec.INSTANCE);
 Configuration hConf = ConfigurationUtil.get(conf, Constants.Explore.HCONF_KEY, HConfCodec.INSTANCE);
 Injector injector = createInjector(cConf, hConf);
 ZKClientService zkClientService = injector.getInstance(ZKClientService.class);
 zkClientService.startAndWait();
 DatasetFramework datasetFramework = injector.getInstance(DatasetFramework.class);
 SystemDatasetInstantiatorFactory datasetInstantiatorFactory =
  injector.getInstance(SystemDatasetInstantiatorFactory.class);
 return new Context(datasetFramework, zkClientService, datasetInstantiatorFactory);
}

代码示例来源：origin: cdapio/cdap

private DistributedKeyManager getKeyManager(Injector injector, boolean expectLeader) throws Exception {
 ZKClientService zk = injector.getInstance(ZKClientService.class);
 zk.startAndWait();
 WaitableDistributedKeyManager keyManager =
  new WaitableDistributedKeyManager(injector.getInstance(CConfiguration.class),
    injector.getInstance(Key.get(new TypeLiteral<Codec<KeyIdentifier>>() { })),
    zk);
 keyManager.startAndWait();
 if (expectLeader) {
  keyManager.waitForLeader(5000, TimeUnit.MILLISECONDS);
 }
 return keyManager;
}

代码示例来源：origin: caskdata/coopr

private ZKClientService createZKClient() {
  ZKClientService zkClient = ZKClientService.Builder.of(zkServer.getConnectionStr()).build();
  zkClient.startAndWait();

  return zkClient;
 }
}

代码示例来源：origin: cdapio/cdap

@BeforeClass
public static void init() throws IOException {
 zkServer = InMemoryZKServer.builder().setDataDir(TMP_FOLDER.newFolder()).build();
 zkServer.startAndWait();
 CConfiguration cConf = CConfiguration.create();
 cConf.set(Constants.Zookeeper.QUORUM, zkServer.getConnectionStr());
 Injector injector = Guice.createInjector(new ConfigModule(cConf),
                      new ZKClientModule());
 zkClientService = injector.getInstance(ZKClientService.class);
 zkClientService.startAndWait();
}

代码示例来源：origin: cdapio/cdap

@BeforeClass
public static void init() throws IOException {
 zkServer = InMemoryZKServer.builder().setDataDir(tmpFolder.newFolder()).build();
 zkServer.startAndWait();
 zkClient = ZKClientService.Builder.of(zkServer.getConnectionStr()).build();
 zkClient.startAndWait();
}

代码示例来源：origin: caskdata/coopr

@Before
public void before() throws IOException {
 zkServer = InMemoryZKServer.builder().setDataDir(tmpFolder.newFolder()).setTickTime(1000).build();
 zkServer.startAndWait();
 zkClient = ZKClientService.Builder.of(zkServer.getConnectionStr()).build();
 zkClient.startAndWait();
}

代码示例来源：origin: caskdata/coopr

@Before
public void before() throws IOException {
 zkServer = InMemoryZKServer.builder().setDataDir(tmpFolder.newFolder()).setTickTime(1000).build();
 zkServer.startAndWait();
 zkClient = ZKClientService.Builder.of(zkServer.getConnectionStr()).build();
 zkClient.startAndWait();
}

代码示例来源：origin: caskdata/coopr

@BeforeClass
public static void beforeClass() throws SQLException, ClassNotFoundException, IOException {
 zkServer = InMemoryZKServer.builder().setDataDir(tmpFolder.newFolder()).setTickTime(1000).build();
 zkServer.startAndWait();
 zkClient = ZKClientService.Builder.of(zkServer.getConnectionStr()).build();
 zkClient.startAndWait();
}