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

ZKServerComponent.<init>介绍

暂无

代码示例

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

@Before
public void setup() throws Exception {
 zkComponent = new ZKServerComponent();
 zkComponent.start();
 client = ConfigurationsUtils.getClient(zkComponent.getConnectionString());

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

@BeforeClass
public static void setupBeforeClass() throws Exception {
 UnitTestHelper.setJavaLoggingLevel(Level.SEVERE);
 LOG.info("Starting up YARN cluster");
 zkServerComponent = new ZKServerComponent();
 yarnComponent = new YarnComponent().withApplicationMasterClass(ApplicationMaster.class).withTestName(MaasIntegrationTest.class.getSimpleName());
 runner = new ComponentRunner.Builder()
     .withComponent("yarn", yarnComponent)
     .withComponent("zk", zkServerComponent)
     .withMillisecondsBetweenAttempts(15000)
     .withNumRetries(10)
     .build();
 runner.start();
 String zookeeperUrl = zkServerComponent.getConnectionString();
 RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
 client = CuratorFrameworkFactory.newClient(zookeeperUrl, retryPolicy);
 client.start();
}