本文整理了Java中com.twitter.distributedlog.impl.metadata.ZKLogMetadata.getMaxTxIdPath()
方法的一些代码示例,展示了ZKLogMetadata.getMaxTxIdPath()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZKLogMetadata.getMaxTxIdPath()
方法的具体详情如下:
包路径:com.twitter.distributedlog.impl.metadata.ZKLogMetadata
类名称:ZKLogMetadata
方法名:getMaxTxIdPath
暂无
代码示例来源:origin: twitter/distributedlog
public void deleteLog() throws IOException {
lock.checkOwnershipAndReacquire();
FutureUtils.result(purgeLogSegmentsOlderThanTxnId(-1));
try {
Utils.closeQuietly(lock);
zooKeeperClient.get().exists(logMetadata.getLogSegmentsPath(), false);
zooKeeperClient.get().exists(logMetadata.getMaxTxIdPath(), false);
if (logMetadata.getLogRootPath().toLowerCase().contains("distributedlog")) {
ZKUtil.deleteRecursive(zooKeeperClient.get(), logMetadata.getLogRootPath());
} else {
LOG.warn("Skip deletion of unrecognized ZK Path {}", logMetadata.getLogRootPath());
}
} catch (InterruptedException ie) {
LOG.error("Interrupted while deleting log znodes", ie);
throw new DLInterruptedException("Interrupted while deleting " + logMetadata.getLogRootPath(), ie);
} catch (KeeperException ke) {
LOG.error("Error deleting" + logMetadata.getLogRootPath() + " in zookeeper", ke);
}
}
代码示例来源:origin: twitter/distributedlog
@Test(timeout = 60000)
public void testGetPaths() throws Exception {
String rootPath = "/test-get-paths";
URI uri = DLMTestUtil.createDLMURI(2181, rootPath);
String logName = "test-log";
String logIdentifier = "<default>";
String logRootPath = uri.getPath() + "/" + logName + "/" + logIdentifier;
String logSegmentName = "test-segment";
ZKLogMetadata logMetadata = new ZKLogMetadata(uri, logName, logIdentifier);
assertEquals("wrong log name", logName, logMetadata.getLogName());
assertEquals("wrong root path", logRootPath, logMetadata.getLogRootPath());
assertEquals("wrong log segments path",
logRootPath + LOGSEGMENTS_PATH,
logMetadata.getLogSegmentsPath());
assertEquals("wrong log segment path",
logRootPath + LOGSEGMENTS_PATH + "/" + logSegmentName,
logMetadata.getLogSegmentPath(logSegmentName));
assertEquals("wrong lock path",
logRootPath + LOCK_PATH, logMetadata.getLockPath());
assertEquals("wrong max tx id path",
logRootPath + MAX_TXID_PATH, logMetadata.getMaxTxIdPath());
assertEquals("wrong allocation path",
logRootPath + ALLOCATION_PATH, logMetadata.getAllocationPath());
assertEquals("wrong qualified name",
logName + ":" + logIdentifier, logMetadata.getFullyQualifiedName());
}
内容来源于网络,如有侵权,请联系作者删除!