org.apache.hadoop.hbase.zookeeper.ZKMetadata类的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(8.7k)|赞(0)|评价(0)|浏览(138)

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

ZKMetadata介绍

[英]The metadata append to the start of data on zookeeper.
[中]元数据附加到zookeeper上数据的开头。

代码示例

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

private static String getClusterId(byte[] data) throws DeserializationException {
 if (data == null || data.length == 0) {
  return null;
 }
 data = removeMetaData(data);
 return ClusterId.parseFrom(data).toString();
}

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

throws KeeperException, InterruptedException {
try (TraceScope scope = TraceUtil.createTrace("RecoverableZookeeper.create")) {
 byte[] newData = ZKMetadata.appendMetaData(id, data);
 switch (createMode) {
  case EPHEMERAL:

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

@Override
 public void processResult(int rc, String path, Object ctx, byte[] data, Stat stat) {
  SplitLogCounters.tot_wkr_get_data_result.increment();
  if (rc != 0) {
   LOG.warn("getdata rc = " + KeeperException.Code.get(rc) + " " + path);
   getDataSetWatchFailure(path);
   return;
  }
  data = ZKMetadata.removeMetaData(data);
  getDataSetWatchSuccess(path, data);
 }
}

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

/**
 * Convert Iterable of {@link org.apache.zookeeper.Op} we got into the ZooKeeper.Op
 * instances to actually pass to multi (need to do this in order to appendMetaData).
 */
private Iterable<Op> prepareZKMulti(Iterable<Op> ops) throws UnsupportedOperationException {
 if(ops == null) {
  return null;
 }
 List<Op> preparedOps = new LinkedList<>();
 for (Op op : ops) {
  if (op.getType() == ZooDefs.OpCode.create) {
   CreateRequest create = (CreateRequest)op.toRequestRecord();
   preparedOps.add(Op.create(create.getPath(), ZKMetadata.appendMetaData(id, create.getData()),
    create.getAcl(), create.getFlags()));
  } else if (op.getType() == ZooDefs.OpCode.delete) {
   // no need to appendMetaData for delete
   preparedOps.add(op);
  } else if (op.getType() == ZooDefs.OpCode.setData) {
   SetDataRequest setData = (SetDataRequest)op.toRequestRecord();
   preparedOps.add(Op.setData(setData.getPath(),
       ZKMetadata.appendMetaData(id, setData.getData()), setData.getVersion()));
  } else {
   throw new UnsupportedOperationException("Unexpected ZKOp type: " + op.getClass().getName());
  }
 }
 return preparedOps;
}

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

private static ZooKeeperProtos.Master getMasterProto(byte[] data) throws IOException {
 if (data == null || data.length == 0) {
  return null;
 }
 data = removeMetaData(data);
 int prefixLen = lengthOfPBMagic();
 return ZooKeeperProtos.Master.parser().parseFrom(data, prefixLen, data.length - prefixLen);
}

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

try (TraceScope scope = TraceUtil.createTrace("RecoverableZookeeper.setData")) {
 RetryCounter retryCounter = retryCounterFactory.create();
 byte[] newData = ZKMetadata.appendMetaData(id, data);
 boolean isRetry = false;
 long startTime;

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

private static ZooKeeperProtos.MetaRegionServer getMetaProto(byte[] data) throws IOException {
 if (data == null || data.length == 0) {
  return null;
 }
 data = removeMetaData(data);
 int prefixLen = lengthOfPBMagic();
 return ZooKeeperProtos.MetaRegionServer.parser().parseFrom(data, prefixLen,
  data.length - prefixLen);
}

代码示例来源：origin: org.apache.hbase/hbase-zookeeper

throws KeeperException, InterruptedException {
try (TraceScope scope = TraceUtil.createTrace("RecoverableZookeeper.create")) {
 byte[] newData = ZKMetadata.appendMetaData(id, data);
 switch (createMode) {
  case EPHEMERAL:

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

/**
 * getData is an idempotent operation. Retry before throwing exception
 * @return Data
 */
public byte[] getData(String path, boolean watch, Stat stat)
 throws KeeperException, InterruptedException {
 try (TraceScope scope = TraceUtil.createTrace("RecoverableZookeeper.getData")) {
  RetryCounter retryCounter = retryCounterFactory.create();
  while (true) {
   try {
    long startTime = EnvironmentEdgeManager.currentTime();
    byte[] revData = checkZk().getData(path, watch, stat);
    return ZKMetadata.removeMetaData(revData);
   } catch (KeeperException e) {
    switch (e.code()) {
     case CONNECTIONLOSS:
      retryOrThrow(retryCounter, e, "getData");
      break;
     case OPERATIONTIMEOUT:
      retryOrThrow(retryCounter, e, "getData");
      break;
     default:
      throw e;
    }
   }
   retryCounter.sleepUntilNextRetry();
  }
 }
}

代码示例来源：origin: org.apache.hbase/hbase-zookeeper

/**
 * Convert Iterable of {@link org.apache.zookeeper.Op} we got into the ZooKeeper.Op
 * instances to actually pass to multi (need to do this in order to appendMetaData).
 */
private Iterable<Op> prepareZKMulti(Iterable<Op> ops) throws UnsupportedOperationException {
 if(ops == null) {
  return null;
 }
 List<Op> preparedOps = new LinkedList<>();
 for (Op op : ops) {
  if (op.getType() == ZooDefs.OpCode.create) {
   CreateRequest create = (CreateRequest)op.toRequestRecord();
   preparedOps.add(Op.create(create.getPath(), ZKMetadata.appendMetaData(id, create.getData()),
    create.getAcl(), create.getFlags()));
  } else if (op.getType() == ZooDefs.OpCode.delete) {
   // no need to appendMetaData for delete
   preparedOps.add(op);
  } else if (op.getType() == ZooDefs.OpCode.setData) {
   SetDataRequest setData = (SetDataRequest)op.toRequestRecord();
   preparedOps.add(Op.setData(setData.getPath(),
       ZKMetadata.appendMetaData(id, setData.getData()), setData.getVersion()));
  } else {
   throw new UnsupportedOperationException("Unexpected ZKOp type: " + op.getClass().getName());
  }
 }
 return preparedOps;
}

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

/**
 * getData is an idempotent operation. Retry before throwing exception
 * @return Data
 */
public byte[] getData(String path, Watcher watcher, Stat stat)
 throws KeeperException, InterruptedException {
 try (TraceScope scope = TraceUtil.createTrace("RecoverableZookeeper.getData")) {
  RetryCounter retryCounter = retryCounterFactory.create();
  while (true) {
   try {
    long startTime = EnvironmentEdgeManager.currentTime();
    byte[] revData = checkZk().getData(path, watcher, stat);
    return ZKMetadata.removeMetaData(revData);
   } catch (KeeperException e) {
    switch (e.code()) {
     case CONNECTIONLOSS:
      retryOrThrow(retryCounter, e, "getData");
      break;
     case OPERATIONTIMEOUT:
      retryOrThrow(retryCounter, e, "getData");
      break;
     default:
      throw e;
    }
   }
   retryCounter.sleepUntilNextRetry();
  }
 }
}

代码示例来源：origin: org.apache.hbase/hbase-zookeeper

try (TraceScope scope = TraceUtil.createTrace("RecoverableZookeeper.setData")) {
 RetryCounter retryCounter = retryCounterFactory.create();
 byte[] newData = ZKMetadata.appendMetaData(id, data);
 boolean isRetry = false;
 long startTime;

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

return;
data = ZKMetadata.removeMetaData(data);
SplitLogTask slt = SplitLogTask.parseFrom(data);
if (slt.isUnassigned()) {

代码示例来源：origin: org.apache.hbase/hbase-client

private static String getClusterId(byte[] data) throws DeserializationException {
 if (data == null || data.length == 0) {
  return null;
 }
 data = removeMetaData(data);
 return ClusterId.parseFrom(data).toString();
}

代码示例来源：origin: org.apache.hbase/hbase-client

private static ZooKeeperProtos.Master getMasterProto(byte[] data) throws IOException {
 if (data == null || data.length == 0) {
  return null;
 }
 data = removeMetaData(data);
 int prefixLen = lengthOfPBMagic();
 return ZooKeeperProtos.Master.parser().parseFrom(data, prefixLen, data.length - prefixLen);
}

代码示例来源：origin: org.apache.hbase/hbase-client

private static ZooKeeperProtos.MetaRegionServer getMetaProto(byte[] data) throws IOException {
 if (data == null || data.length == 0) {
  return null;
 }
 data = removeMetaData(data);
 int prefixLen = lengthOfPBMagic();
 return ZooKeeperProtos.MetaRegionServer.parser().parseFrom(data, prefixLen,
  data.length - prefixLen);
}

代码示例来源：origin: com.aliyun.hbase/alihbase-client

private static String getClusterId(byte[] data) throws DeserializationException {
 if (data == null || data.length == 0) {
  return null;
 }
 data = removeMetaData(data);
 return ClusterId.parseFrom(data).toString();
}

代码示例来源：origin: com.aliyun.hbase/alihbase-client

private static ZooKeeperProtos.MetaRegionServer getMetaProto(byte[] data) throws IOException {
 if (data == null || data.length == 0) {
  return null;
 }
 data = removeMetaData(data);
 int prefixLen = lengthOfPBMagic();
 return ZooKeeperProtos.MetaRegionServer.parser().parseFrom(data, prefixLen,
  data.length - prefixLen);
}

代码示例来源：origin: com.aliyun.hbase/alihbase-client

private static ZooKeeperProtos.Master getMasterProto(byte[] data) throws IOException {
 if (data == null || data.length == 0) {
  return null;
 }
 data = removeMetaData(data);
 int prefixLen = lengthOfPBMagic();
 return ZooKeeperProtos.Master.parser().parseFrom(data, prefixLen, data.length - prefixLen);
}

代码示例来源：origin: org.apache.hbase/hbase-zookeeper

/**
 * getData is an idempotent operation. Retry before throwing exception
 * @return Data
 */
public byte[] getData(String path, boolean watch, Stat stat)
 throws KeeperException, InterruptedException {
 try (TraceScope scope = TraceUtil.createTrace("RecoverableZookeeper.getData")) {
  RetryCounter retryCounter = retryCounterFactory.create();
  while (true) {
   try {
    long startTime = EnvironmentEdgeManager.currentTime();
    byte[] revData = checkZk().getData(path, watch, stat);
    return ZKMetadata.removeMetaData(revData);
   } catch (KeeperException e) {
    switch (e.code()) {
     case CONNECTIONLOSS:
      retryOrThrow(retryCounter, e, "getData");
      break;
     case OPERATIONTIMEOUT:
      retryOrThrow(retryCounter, e, "getData");
      break;
     default:
      throw e;
    }
   }
   retryCounter.sleepUntilNextRetry();
  }
 }
}

内容来源于网络，如有侵权，请联系作者删除！

ZKMetadata

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    ZKMetadata类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com