本文整理了Java中org.apache.druid.server.initialization.ZkPathsConfig.<init>()
方法的一些代码示例,展示了ZkPathsConfig.<init>()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZkPathsConfig.<init>()
方法的具体详情如下:
包路径:org.apache.druid.server.initialization.ZkPathsConfig
类名称:ZkPathsConfig
方法名:<init>
暂无
代码示例来源:origin: apache/incubator-druid
public BrokerServerViewTest()
{
jsonMapper = TestHelper.makeJsonMapper();
zkPathsConfig = new ZkPathsConfig();
}
代码示例来源:origin: apache/incubator-druid
public CuratorDruidCoordinatorTest()
{
jsonMapper = TestHelper.makeJsonMapper();
zkPathsConfig = new ZkPathsConfig();
}
代码示例来源:origin: apache/incubator-druid
public CoordinatorServerViewTest()
{
jsonMapper = TestHelper.makeJsonMapper();
zkPathsConfig = new ZkPathsConfig();
inventoryPath = zkPathsConfig.getLiveSegmentsPath();
}
代码示例来源:origin: apache/incubator-druid
@Test
public void testFullOverride() throws Exception
{
final DefaultObjectMapper mapper = new DefaultObjectMapper();
final ZkPathsConfig zkPathsConfig = new ZkPathsConfig();
IndexerZkConfig indexerZkConfig = new IndexerZkConfig(
zkPathsConfig,
"/druid/prod",
"/druid/prod/a",
"/druid/prod/t",
"/druid/prod/s"
);
Map<String, String> value = mapper.readValue(
mapper.writeValueAsString(indexerZkConfig), JacksonUtils.TYPE_REFERENCE_MAP_STRING_STRING
);
IndexerZkConfig newConfig = new IndexerZkConfig(
zkPathsConfig,
value.get("base"),
value.get("announcementsPath"),
value.get("tasksPath"),
value.get("statusPath")
);
Assert.assertEquals(indexerZkConfig, newConfig);
}
}
代码示例来源:origin: apache/incubator-druid
taskStorage,
EasyMock.createNiceMock(CuratorFramework.class),
new IndexerZkConfig(new ZkPathsConfig(), null, null, null, null)
);
代码示例来源:origin: apache/incubator-druid
new ZkPathsConfig()
代码示例来源:origin: apache/incubator-druid
coordinator = new DruidCoordinator(
druidCoordinatorConfig,
new ZkPathsConfig()
代码示例来源:origin: apache/incubator-druid
new ZkPathsConfig(),
objectMapper
);
new ZkPathsConfig(),
objectMapper
);
内容来源于网络,如有侵权,请联系作者删除!