个人中心
gpt4 book ai didi

com.twitter.distributedlog.impl.metadata.ZKLogMetadata.getMaxTxIdPath()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-13 11:05:39 27 4
gpt4 key购买 nike

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

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());
}

27 4 0
文章推荐： com.twitter.distributedlog.impl.metadata.ZKLogMetadataForWriter.pathExists()方法的使用及代码示例
文章推荐： com.twitter.distributedlog.impl.metadata.ZKLogMetadataForWriter.checkLogMetadataPaths()方法的使用及代码示例
文章推荐： com.twitter.distributedlog.metadata.ZkMetadataResolver类的使用及代码示例
文章推荐： com.twitter.finagle.common.zookeeper.ZooKeeperClient.registerExpirationHandler()方法的使用及代码示例
知者
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
全站热门文章
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com