org.apache.hadoop.yarn.server.resourcemanager.recovery.ZKRMStateStore.existsWithRetries()方法的使用及代码示例

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

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

ZKRMStateStore.existsWithRetries介绍

暂无

代码示例

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-resourcemanager

@Override
public synchronized void deleteStore() throws Exception {
 if (existsWithRetries(zkRootNodePath, false) != null) {
  deleteWithRetries(zkRootNodePath, false);
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

@Override
public synchronized void deleteStore() throws Exception {
 if (existsWithRetries(zkRootNodePath, false) != null) {
  deleteWithRetries(zkRootNodePath, false);
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

@Override
protected synchronized void removeRMDTMasterKeyState(
  DelegationKey delegationKey) throws Exception {
 String nodeRemovePath =
   getNodePath(dtMasterKeysRootPath, DELEGATION_KEY_PREFIX
     + delegationKey.getKeyId());
 if (LOG.isDebugEnabled()) {
  LOG.debug("Removing RMDelegationKey_" + delegationKey.getKeyId());
 }
 if (existsWithRetries(nodeRemovePath, false) != null) {
  doDeleteMultiWithRetries(Op.delete(nodeRemovePath, -1));
 } else {
  LOG.debug("Attempted to delete a non-existing znode " + nodeRemovePath);
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

@Override
protected synchronized void removeRMDelegationTokenState(
  RMDelegationTokenIdentifier rmDTIdentifier) throws Exception {
 String nodeRemovePath =
   getNodePath(delegationTokensRootPath, DELEGATION_TOKEN_PREFIX
     + rmDTIdentifier.getSequenceNumber());
 if (LOG.isDebugEnabled()) {
  LOG.debug("Removing RMDelegationToken_"
    + rmDTIdentifier.getSequenceNumber());
 }
 if (existsWithRetries(nodeRemovePath, false) != null) {
  ArrayList<Op> opList = new ArrayList<Op>();
  opList.add(Op.delete(nodeRemovePath, -1));
  doDeleteMultiWithRetries(opList);
 } else {
  LOG.debug("Attempted to delete a non-existing znode " + nodeRemovePath);
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-resourcemanager

@Override
protected synchronized void removeRMDelegationTokenState(
  RMDelegationTokenIdentifier rmDTIdentifier) throws Exception {
 String nodeRemovePath =
   getNodePath(delegationTokensRootPath, DELEGATION_TOKEN_PREFIX
     + rmDTIdentifier.getSequenceNumber());
 if (LOG.isDebugEnabled()) {
  LOG.debug("Removing RMDelegationToken_"
    + rmDTIdentifier.getSequenceNumber());
 }
 if (existsWithRetries(nodeRemovePath, false) != null) {
  ArrayList<Op> opList = new ArrayList<Op>();
  opList.add(Op.delete(nodeRemovePath, -1));
  doDeleteMultiWithRetries(opList);
 } else {
  LOG.debug("Attempted to delete a non-existing znode " + nodeRemovePath);
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-resourcemanager

@Override
protected synchronized void removeRMDTMasterKeyState(
  DelegationKey delegationKey) throws Exception {
 String nodeRemovePath =
   getNodePath(dtMasterKeysRootPath, DELEGATION_KEY_PREFIX
     + delegationKey.getKeyId());
 if (LOG.isDebugEnabled()) {
  LOG.debug("Removing RMDelegationKey_" + delegationKey.getKeyId());
 }
 if (existsWithRetries(nodeRemovePath, false) != null) {
  doDeleteMultiWithRetries(Op.delete(nodeRemovePath, -1));
 } else {
  LOG.debug("Attempted to delete a non-existing znode " + nodeRemovePath);
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-resourcemanager

@Override
protected synchronized void updateRMDelegationTokenState(
  RMDelegationTokenIdentifier rmDTIdentifier, Long renewDate)
  throws Exception {
 ArrayList<Op> opList = new ArrayList<Op>();
 String nodeRemovePath =
   getNodePath(delegationTokensRootPath, DELEGATION_TOKEN_PREFIX
     + rmDTIdentifier.getSequenceNumber());
 if (existsWithRetries(nodeRemovePath, false) == null) {
  // in case znode doesn't exist
  addStoreOrUpdateOps(opList, rmDTIdentifier, renewDate, false);
  LOG.debug("Attempted to update a non-existing znode " + nodeRemovePath);
 } else {
  // in case znode exists
  addStoreOrUpdateOps(opList, rmDTIdentifier, renewDate, true);
 }
 doStoreMultiWithRetries(opList);
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-resourcemanager

@Override
public synchronized void updateApplicationStateInternal(ApplicationId appId,
  ApplicationStateData appStateDataPB) throws Exception {
 String nodeUpdatePath = getNodePath(rmAppRoot, appId.toString());
 if (LOG.isDebugEnabled()) {
  LOG.debug("Storing final state info for app: " + appId + " at: "
    + nodeUpdatePath);
 }
 byte[] appStateData = appStateDataPB.getProto().toByteArray();
 if (existsWithRetries(nodeUpdatePath, false) != null) {
  setDataWithRetries(nodeUpdatePath, appStateData, -1);
 } else {
  createWithRetries(nodeUpdatePath, appStateData, zkAcl,
   CreateMode.PERSISTENT);
  LOG.debug(appId + " znode didn't exist. Created a new znode to"
    + " update the application state.");
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

@Override
public synchronized void updateApplicationStateInternal(ApplicationId appId,
  ApplicationStateData appStateDataPB) throws Exception {
 String nodeUpdatePath = getNodePath(rmAppRoot, appId.toString());
 if (LOG.isDebugEnabled()) {
  LOG.debug("Storing final state info for app: " + appId + " at: "
    + nodeUpdatePath);
 }
 byte[] appStateData = appStateDataPB.getProto().toByteArray();
 if (existsWithRetries(nodeUpdatePath, false) != null) {
  setDataWithRetries(nodeUpdatePath, appStateData, -1);
 } else {
  createWithRetries(nodeUpdatePath, appStateData, zkAcl,
   CreateMode.PERSISTENT);
  LOG.debug(appId + " znode didn't exist. Created a new znode to"
    + " update the application state.");
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

@Override
protected synchronized void updateRMDelegationTokenState(
  RMDelegationTokenIdentifier rmDTIdentifier, Long renewDate)
  throws Exception {
 ArrayList<Op> opList = new ArrayList<Op>();
 String nodeRemovePath =
   getNodePath(delegationTokensRootPath, DELEGATION_TOKEN_PREFIX
     + rmDTIdentifier.getSequenceNumber());
 if (existsWithRetries(nodeRemovePath, false) == null) {
  // in case znode doesn't exist
  addStoreOrUpdateOps(opList, rmDTIdentifier, renewDate, false);
  LOG.debug("Attempted to update a non-existing znode " + nodeRemovePath);
 } else {
  // in case znode exists
  addStoreOrUpdateOps(opList, rmDTIdentifier, renewDate, true);
 }
 doStoreMultiWithRetries(opList);
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

@Override
protected synchronized Version loadVersion() throws Exception {
 String versionNodePath = getNodePath(zkRootNodePath, VERSION_NODE);
 if (existsWithRetries(versionNodePath, false) != null) {
  byte[] data = getDataWithRetries(versionNodePath, false);
  Version version =
    new VersionPBImpl(VersionProto.parseFrom(data));
  return version;
 }
 return null;
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-resourcemanager

@Override
protected synchronized Version loadVersion() throws Exception {
 String versionNodePath = getNodePath(zkRootNodePath, VERSION_NODE);
 if (existsWithRetries(versionNodePath, false) != null) {
  byte[] data = getDataWithRetries(versionNodePath, false);
  Version version =
    new VersionPBImpl(VersionProto.parseFrom(data));
  return version;
 }
 return null;
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-resourcemanager

@Override
protected synchronized void storeVersion() throws Exception {
 String versionNodePath = getNodePath(zkRootNodePath, VERSION_NODE);
 byte[] data =
   ((VersionPBImpl) CURRENT_VERSION_INFO).getProto().toByteArray();
 if (existsWithRetries(versionNodePath, false) != null) {
  setDataWithRetries(versionNodePath, data, -1);
 } else {
  createWithRetries(versionNodePath, data, zkAcl, CreateMode.PERSISTENT);
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

@Override
protected synchronized void storeVersion() throws Exception {
 String versionNodePath = getNodePath(zkRootNodePath, VERSION_NODE);
 byte[] data =
   ((VersionPBImpl) CURRENT_VERSION_INFO).getProto().toByteArray();
 if (existsWithRetries(versionNodePath, false) != null) {
  setDataWithRetries(versionNodePath, data, -1);
 } else {
  createWithRetries(versionNodePath, data, zkAcl, CreateMode.PERSISTENT);
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

@Override
public synchronized void updateApplicationAttemptStateInternal(
  ApplicationAttemptId appAttemptId,
  ApplicationAttemptStateData attemptStateDataPB)
  throws Exception {
 String appIdStr = appAttemptId.getApplicationId().toString();
 String appAttemptIdStr = appAttemptId.toString();
 String appDirPath = getNodePath(rmAppRoot, appIdStr);
 String nodeUpdatePath = getNodePath(appDirPath, appAttemptIdStr);
 if (LOG.isDebugEnabled()) {
  LOG.debug("Storing final state info for attempt: " + appAttemptIdStr
    + " at: " + nodeUpdatePath);
 }
 byte[] attemptStateData = attemptStateDataPB.getProto().toByteArray();
 if (existsWithRetries(nodeUpdatePath, false) != null) {
  setDataWithRetries(nodeUpdatePath, attemptStateData, -1);
 } else {
  createWithRetries(nodeUpdatePath, attemptStateData, zkAcl,
   CreateMode.PERSISTENT);
  LOG.debug(appAttemptId + " znode didn't exist. Created a new znode to"
    + " update the application attempt state.");
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-resourcemanager

@Override
public synchronized void updateApplicationAttemptStateInternal(
  ApplicationAttemptId appAttemptId,
  ApplicationAttemptStateData attemptStateDataPB)
  throws Exception {
 String appIdStr = appAttemptId.getApplicationId().toString();
 String appAttemptIdStr = appAttemptId.toString();
 String appDirPath = getNodePath(rmAppRoot, appIdStr);
 String nodeUpdatePath = getNodePath(appDirPath, appAttemptIdStr);
 if (LOG.isDebugEnabled()) {
  LOG.debug("Storing final state info for attempt: " + appAttemptIdStr
    + " at: " + nodeUpdatePath);
 }
 byte[] attemptStateData = attemptStateDataPB.getProto().toByteArray();
 if (existsWithRetries(nodeUpdatePath, false) != null) {
  setDataWithRetries(nodeUpdatePath, attemptStateData, -1);
 } else {
  createWithRetries(nodeUpdatePath, attemptStateData, zkAcl,
   CreateMode.PERSISTENT);
  LOG.debug(appAttemptId + " znode didn't exist. Created a new znode to"
    + " update the application attempt state.");
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-resourcemanager

@Override
public synchronized long getAndIncrementEpoch() throws Exception {
 String epochNodePath = getNodePath(zkRootNodePath, EPOCH_NODE);
 long currentEpoch = 0;
 if (existsWithRetries(epochNodePath, false) != null) {
  // load current epoch
  byte[] data = getDataWithRetries(epochNodePath, false);
  Epoch epoch = new EpochPBImpl(EpochProto.parseFrom(data));
  currentEpoch = epoch.getEpoch();
  // increment epoch and store it
  byte[] storeData = Epoch.newInstance(currentEpoch + 1).getProto()
    .toByteArray();
  setDataWithRetries(epochNodePath, storeData, -1);
 } else {
  // initialize epoch node with 1 for the next time.
  byte[] storeData = Epoch.newInstance(currentEpoch + 1).getProto()
    .toByteArray();
  createWithRetries(epochNodePath, storeData, zkAcl, CreateMode.PERSISTENT);
 }
 return currentEpoch;
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

@Override
public synchronized long getAndIncrementEpoch() throws Exception {
 String epochNodePath = getNodePath(zkRootNodePath, EPOCH_NODE);
 long currentEpoch = 0;
 if (existsWithRetries(epochNodePath, false) != null) {
  // load current epoch
  byte[] data = getDataWithRetries(epochNodePath, false);
  Epoch epoch = new EpochPBImpl(EpochProto.parseFrom(data));
  currentEpoch = epoch.getEpoch();
  // increment epoch and store it
  byte[] storeData = Epoch.newInstance(currentEpoch + 1).getProto()
    .toByteArray();
  setDataWithRetries(epochNodePath, storeData, -1);
 } else {
  // initialize epoch node with 1 for the next time.
  byte[] storeData = Epoch.newInstance(currentEpoch + 1).getProto()
    .toByteArray();
  createWithRetries(epochNodePath, storeData, zkAcl, CreateMode.PERSISTENT);
 }
 return currentEpoch;
}

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

ZKRMStateStore

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    ZKRMStateStore类方法

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