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

ZKModule介绍

[英]Provides Guice binding to ZKClient and ZKClientService.
[中]提供与ZKClient和ZKClientService的GUI绑定。

代码示例

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

@Override
protected void configure() {
 /**
  * ZKClientService is provided by the provider method
  * {@link #provideZKClientService(org.apache.hadoop.conf.Configuration)}.
  */
 bind(ZKClient.class).to(ZKClientService.class);
}

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

/**
 * Invoked by jsvc to start the program.
 */
public void start() throws Exception {
 Injector injector = Guice.createInjector(
  new ConfigModule(conf),
  new ZKModule(),
  new DiscoveryModules().getDistributedModules(),
  new TransactionModules().getDistributedModules(),
  new TransactionClientModule()
 );
 ZKClientService zkClientService = injector.getInstance(ZKClientService.class);
 zkClientService.startAndWait();
 // start a tx server
 txService = injector.getInstance(TransactionService.class);
 try {
  LOG.info("Starting {}", getClass().getSimpleName());
  txService.startAndWait();
 } catch (Exception e) {
  System.err.println("Failed to start service: " + e.getMessage());
 }
}

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

/**
 * Invoked by jsvc to start the program.
 */
public void start() throws Exception {
 Injector injector = Guice.createInjector(
  new ConfigModule(conf),
  new ZKModule(),
  new DiscoveryModules().getDistributedModules(),
  new TransactionModules().getDistributedModules(),
  new TransactionClientModule()
 );
 ZKClientService zkClientService = injector.getInstance(ZKClientService.class);
 zkClientService.startAndWait();
 // start a tx server
 txService = injector.getInstance(TransactionService.class);
 try {
  LOG.info("Starting {}", getClass().getSimpleName());
  txService.startAndWait();
 } catch (Exception e) {
  System.err.println("Failed to start service: " + e.getMessage());
 }
}

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

/**
 * Sets up common resources required by all clients.
 */
public void init() throws IOException {
 Injector injector = Guice.createInjector(
   new ConfigModule(conf),
   new ZKModule(),
   new DiscoveryModules().getDistributedModules(),
   new TransactionModules().getDistributedModules(),
   new TransactionClientModule()
 );
 zkClient = injector.getInstance(ZKClientService.class);
 zkClient.startAndWait();
 txClient = injector.getInstance(TransactionServiceClient.class);
 createTableIfNotExists(conf, TABLE, new byte[][]{ FAMILY });
 conn = HConnectionManager.createConnection(conf);
}

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

@Override
protected void configure() {
 /**
  * ZKClientService is provided by the provider method
  * {@link #provideZKClientService(org.apache.hadoop.conf.Configuration)}.
  */
 bind(ZKClient.class).to(ZKClientService.class);
}

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

/**
 * Sets up common resources required by all clients.
 */
public void init() throws IOException {
 Injector injector = Guice.createInjector(
   new ConfigModule(conf),
   new ZKModule(),
   new DiscoveryModules().getDistributedModules(),
   new TransactionModules().getDistributedModules(),
   new TransactionClientModule()
 );
 zkClient = injector.getInstance(ZKClientService.class);
 zkClient.startAndWait();
 txClient = injector.getInstance(TransactionServiceClient.class);
 createTableIfNotExists(conf, TABLE, new byte[][]{ FAMILY });
 conn = HConnectionManager.createConnection(conf);
}

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

Injector injector = Guice.createInjector(
 new ConfigModule(conf),
 new ZKModule(),
 new DiscoveryModules().getDistributedModules(),
 new TransactionModules().getDistributedModules(),

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

Injector injector = Guice.createInjector(
 new ConfigModule(conf),
 new ZKModule(),
 new DiscoveryModules().getDistributedModules(),
 new TransactionModules().getDistributedModules(),

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

new ZKModule(),
new DiscoveryModules().getDistributedModules(),
new TransactionModules().getDistributedModules(),

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

new ZKModule(),
new DiscoveryModules().getDistributedModules(),
new TransactionModules().getDistributedModules(),

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

private void startClientAndTestPool(Configuration conf) throws Exception {
 Injector injector = Guice.createInjector(
  new ConfigModule(conf),
  new ZKModule(),
  new DiscoveryModules().getDistributedModules(),
  new TransactionModules().getDistributedModules(),

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

new ZKModule(),
new DiscoveryModules().getDistributedModules(),
Modules.override(new TransactionModules().getDistributedModules())

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

new ZKModule(),
new DiscoveryModules().getDistributedModules(),
Modules.override(new TransactionModules().getDistributedModules())

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

new ZKModule(),
new DiscoveryModules().getDistributedModules(),
Modules.override(new TransactionModules().getDistributedModules())