1. 包列表
  2. 类列表
  3. org.apache.hadoop.hdfs.server.common.UpgradeStatusReport

Java 类org.apache.hadoop.hdfs.server.common.UpgradeStatusReport 实例源码

项目：hadoop-EAR    文件：UpgradeManagerNamenode.java    
UpgradeStatusReport distributedUpgradeProgress(UpgradeAction action 
                                              ) throws IOException {
  boolean isFinalized = false;
  if(currentUpgrades == null) { // no upgrades are in progress
    FSImage fsimage = namesystem.getFSImage();
    isFinalized = fsimage.isUpgradeFinalized();
    if(isFinalized) // upgrade is finalized
      return null;  // nothing to report
    return new UpgradeStatusReport(fsimage.getLayoutVersion(), 
                                   (short)101, isFinalized);
  }
  UpgradeObjectNamenode curUO = (UpgradeObjectNamenode)currentUpgrades.first();
  boolean details = false;
  switch(action) {
  case GET_STATUS:
    break;
  case DETAILED_STATUS:
    details = true;
    break;
  case FORCE_PROCEED:
    curUO.forceProceed();
  }
  return curUO.getUpgradeStatusReport(details);
}
项目：hadoop-on-lustre    文件：UpgradeManagerNamenode.java    
UpgradeStatusReport distributedUpgradeProgress(UpgradeAction action 
                                              ) throws IOException {
  boolean isFinalized = false;
  if(currentUpgrades == null) { // no upgrades are in progress
    FSImage fsimage = FSNamesystem.getFSNamesystem().getFSImage();
    isFinalized = fsimage.isUpgradeFinalized();
    if(isFinalized) // upgrade is finalized
      return null;  // nothing to report
    return new UpgradeStatusReport(fsimage.getLayoutVersion(), 
                                   (short)101, isFinalized);
  }
  UpgradeObjectNamenode curUO = (UpgradeObjectNamenode)currentUpgrades.first();
  boolean details = false;
  switch(action) {
  case GET_STATUS:
    break;
  case DETAILED_STATUS:
    details = true;
    break;
  case FORCE_PROCEED:
    curUO.forceProceed();
  }
  return curUO.getUpgradeStatusReport(details);
}
项目：cumulus    文件：UpgradeManagerNamenode.java    
synchronized UpgradeStatusReport distributedUpgradeProgress
                                (UpgradeAction action) throws IOException {
  boolean isFinalized = false;
  if(currentUpgrades == null) { // no upgrades are in progress
    FSImage fsimage = namesystem.getFSImage();
    isFinalized = fsimage.isUpgradeFinalized();
    if(isFinalized) // upgrade is finalized
      return null;  // nothing to report
    return new UpgradeStatusReport(fsimage.getLayoutVersion(), 
                                   (short)101, isFinalized);
  }
  UpgradeObjectNamenode curUO = (UpgradeObjectNamenode)currentUpgrades.first();
  boolean details = false;
  switch(action) {
  case GET_STATUS:
    break;
  case DETAILED_STATUS:
    details = true;
    break;
  case FORCE_PROCEED:
    curUO.forceProceed();
  }
  return curUO.getUpgradeStatusReport(details);
}
项目：RDFS    文件：UpgradeManagerNamenode.java    
UpgradeStatusReport distributedUpgradeProgress(UpgradeAction action 
                                              ) throws IOException {
  boolean isFinalized = false;
  if(currentUpgrades == null) { // no upgrades are in progress
    FSImage fsimage = namesystem.getFSImage();
    isFinalized = fsimage.isUpgradeFinalized();
    if(isFinalized) // upgrade is finalized
      return null;  // nothing to report
    return new UpgradeStatusReport(fsimage.getLayoutVersion(), 
                                   (short)101, isFinalized);
  }
  UpgradeObjectNamenode curUO = (UpgradeObjectNamenode)currentUpgrades.first();
  boolean details = false;
  switch(action) {
  case GET_STATUS:
    break;
  case DETAILED_STATUS:
    details = true;
    break;
  case FORCE_PROCEED:
    curUO.forceProceed();
  }
  return curUO.getUpgradeStatusReport(details);
}
项目：hadoop-0.20    文件：UpgradeManagerNamenode.java    
UpgradeStatusReport distributedUpgradeProgress(UpgradeAction action 
                                              ) throws IOException {
  boolean isFinalized = false;
  if(currentUpgrades == null) { // no upgrades are in progress
    FSImage fsimage = FSNamesystem.getFSNamesystem().getFSImage();
    isFinalized = fsimage.isUpgradeFinalized();
    if(isFinalized) // upgrade is finalized
      return null;  // nothing to report
    return new UpgradeStatusReport(fsimage.getLayoutVersion(), 
                                   (short)101, isFinalized);
  }
  UpgradeObjectNamenode curUO = (UpgradeObjectNamenode)currentUpgrades.first();
  boolean details = false;
  switch(action) {
  case GET_STATUS:
    break;
  case DETAILED_STATUS:
    details = true;
    break;
  case FORCE_PROCEED:
    curUO.forceProceed();
  }
  return curUO.getUpgradeStatusReport(details);
}
项目：hortonworks-extension    文件：UpgradeManagerNamenode.java    
UpgradeStatusReport distributedUpgradeProgress(UpgradeAction action 
                                              ) throws IOException {
  boolean isFinalized = false;
  if(currentUpgrades == null) { // no upgrades are in progress
    FSImage fsimage = FSNamesystem.getFSNamesystem().getFSImage();
    isFinalized = fsimage.isUpgradeFinalized();
    if(isFinalized) // upgrade is finalized
      return null;  // nothing to report
    return new UpgradeStatusReport(fsimage.getLayoutVersion(), 
                                   (short)101, isFinalized);
  }
  UpgradeObjectNamenode curUO = (UpgradeObjectNamenode)currentUpgrades.first();
  boolean details = false;
  switch(action) {
  case GET_STATUS:
    break;
  case DETAILED_STATUS:
    details = true;
    break;
  case FORCE_PROCEED:
    curUO.forceProceed();
  }
  return curUO.getUpgradeStatusReport(details);
}
项目：hortonworks-extension    文件：UpgradeManagerNamenode.java    
UpgradeStatusReport distributedUpgradeProgress(UpgradeAction action 
                                              ) throws IOException {
  boolean isFinalized = false;
  if(currentUpgrades == null) { // no upgrades are in progress
    FSImage fsimage = FSNamesystem.getFSNamesystem().getFSImage();
    isFinalized = fsimage.isUpgradeFinalized();
    if(isFinalized) // upgrade is finalized
      return null;  // nothing to report
    return new UpgradeStatusReport(fsimage.getLayoutVersion(), 
                                   (short)101, isFinalized);
  }
  UpgradeObjectNamenode curUO = (UpgradeObjectNamenode)currentUpgrades.first();
  boolean details = false;
  switch(action) {
  case GET_STATUS:
    break;
  case DETAILED_STATUS:
    details = true;
    break;
  case FORCE_PROCEED:
    curUO.forceProceed();
  }
  return curUO.getUpgradeStatusReport(details);
}
项目：hadoop-gpu    文件：UpgradeManagerNamenode.java    
UpgradeStatusReport distributedUpgradeProgress(UpgradeAction action 
                                              ) throws IOException {
  boolean isFinalized = false;
  if(currentUpgrades == null) { // no upgrades are in progress
    FSImage fsimage = FSNamesystem.getFSNamesystem().getFSImage();
    isFinalized = fsimage.isUpgradeFinalized();
    if(isFinalized) // upgrade is finalized
      return null;  // nothing to report
    return new UpgradeStatusReport(fsimage.getLayoutVersion(), 
                                   (short)101, isFinalized);
  }
  UpgradeObjectNamenode curUO = (UpgradeObjectNamenode)currentUpgrades.first();
  boolean details = false;
  switch(action) {
  case GET_STATUS:
    break;
  case DETAILED_STATUS:
    details = true;
    break;
  case FORCE_PROCEED:
    curUO.forceProceed();
  }
  return curUO.getUpgradeStatusReport(details);
}
项目：hadoop-EAR    文件：FailoverClientProtocol.java    
@Override
public UpgradeStatusReport distributedUpgradeProgress(
    final UpgradeAction action) throws IOException {
  return (failoverHandler.new MutableFSCaller<UpgradeStatusReport>() {
    public UpgradeStatusReport call(int r) throws IOException {
      return namenode.distributedUpgradeProgress(action);
    }
  }).callFS();
}
项目：hadoop-EAR    文件：JspHelper.java    
public String getUpgradeStatusText() {
  String statusText = "";
  try {
    UpgradeStatusReport status = 
      fsn.distributedUpgradeProgress(UpgradeAction.GET_STATUS);
    statusText = (status == null ? 
        "There are no upgrades in progress." :
          status.getStatusText(false));
  } catch(IOException e) {
    statusText = "Upgrade status unknown.";
  }
  return statusText;
}
项目：hadoop-EAR    文件：DFSAdmin.java    
/**
 * Command to request current distributed upgrade status, 
 * a detailed status, or to force the upgrade to proceed.
 * 
 * Usage: java DFSAdmin -upgradeProgress [status | details | force]
 * @exception IOException 
 */
public int upgradeProgress(String[] argv, int idx) throws IOException {
  DistributedFileSystem dfs = getDFS();
  if (dfs == null) {
    System.out.println("FileSystem is " + getFS().getUri());
    return -1;
  }
  if (idx != argv.length - 1) {
    printUsage("-upgradeProgress");
    return -1;
  }

  UpgradeAction action;
  if ("status".equalsIgnoreCase(argv[idx])) {
    action = UpgradeAction.GET_STATUS;
  } else if ("details".equalsIgnoreCase(argv[idx])) {
    action = UpgradeAction.DETAILED_STATUS;
  } else if ("force".equalsIgnoreCase(argv[idx])) {
    action = UpgradeAction.FORCE_PROCEED;
  } else {
    printUsage("-upgradeProgress");
    return -1;
  }

  UpgradeStatusReport status = dfs.distributedUpgradeProgress(action);
  String statusText = (status == null ? 
      "There are no upgrades in progress." :
        status.getStatusText(action == UpgradeAction.DETAILED_STATUS));
  System.out.println(statusText);
  return 0;
}
项目：hadoop-on-lustre    文件：JspHelper.java    
public String getUpgradeStatusText() {
  String statusText = "";
  try {
    UpgradeStatusReport status = 
      fsn.distributedUpgradeProgress(UpgradeAction.GET_STATUS);
    statusText = (status == null ? 
        "There are no upgrades in progress." :
          status.getStatusText(false));
  } catch(IOException e) {
    statusText = "Upgrade status unknown.";
  }
  return statusText;
}
项目：hadoop-on-lustre    文件：DFSAdmin.java    
/**
 * Command to request current distributed upgrade status, 
 * a detailed status, or to force the upgrade to proceed.
 * 
 * Usage: java DFSAdmin -upgradeProgress [status | details | force]
 * @exception IOException 
 */
public int upgradeProgress(String[] argv, int idx) throws IOException {
  if (!(fs instanceof DistributedFileSystem)) {
    System.out.println("FileSystem is " + fs.getUri());
    return -1;
  }
  if (idx != argv.length - 1) {
    printUsage("-upgradeProgress");
    return -1;
  }

  UpgradeAction action;
  if ("status".equalsIgnoreCase(argv[idx])) {
    action = UpgradeAction.GET_STATUS;
  } else if ("details".equalsIgnoreCase(argv[idx])) {
    action = UpgradeAction.DETAILED_STATUS;
  } else if ("force".equalsIgnoreCase(argv[idx])) {
    action = UpgradeAction.FORCE_PROCEED;
  } else {
    printUsage("-upgradeProgress");
    return -1;
  }

  DistributedFileSystem dfs = (DistributedFileSystem) fs;
  UpgradeStatusReport status = dfs.distributedUpgradeProgress(action);
  String statusText = (status == null ? 
      "There are no upgrades in progress." :
        status.getStatusText(action == UpgradeAction.DETAILED_STATUS));
  System.out.println(statusText);
  return 0;
}
项目：cumulus    文件：NamenodeJspHelper.java    
static String getUpgradeStatusText(FSNamesystem fsn) {
  String statusText = "";
  try {
    UpgradeStatusReport status = fsn
        .distributedUpgradeProgress(UpgradeAction.GET_STATUS);
    statusText = (status == null ? "There are no upgrades in progress."
        : status.getStatusText(false));
  } catch (IOException e) {
    statusText = "Upgrade status unknown.";
  }
  return statusText;
}
项目：cumulus    文件：DFSAdmin.java    
/**
 * Command to request current distributed upgrade status, 
 * a detailed status, or to force the upgrade to proceed.
 * 
 * Usage: java DFSAdmin -upgradeProgress [status | details | force]
 * @exception IOException 
 */
public int upgradeProgress(String[] argv, int idx) throws IOException {
  if (!(fs instanceof DistributedFileSystem)) {
    System.out.println("FileSystem is " + fs.getUri());
    return -1;
  }
  if (idx != argv.length - 1) {
    printUsage("-upgradeProgress");
    return -1;
  }

  UpgradeAction action;
  if ("status".equalsIgnoreCase(argv[idx])) {
    action = UpgradeAction.GET_STATUS;
  } else if ("details".equalsIgnoreCase(argv[idx])) {
    action = UpgradeAction.DETAILED_STATUS;
  } else if ("force".equalsIgnoreCase(argv[idx])) {
    action = UpgradeAction.FORCE_PROCEED;
  } else {
    printUsage("-upgradeProgress");
    return -1;
  }

  DistributedFileSystem dfs = (DistributedFileSystem) fs;
  UpgradeStatusReport status = dfs.distributedUpgradeProgress(action);
  String statusText = (status == null ? 
      "There are no upgrades in progress." :
        status.getStatusText(action == UpgradeAction.DETAILED_STATUS));
  System.out.println(statusText);
  return 0;
}
项目：RDFS    文件：DistributedAvatarFileSystem.java    
@Override
public UpgradeStatusReport distributedUpgradeProgress(
    final UpgradeAction action) throws IOException {
  return (new MutableFSCaller<UpgradeStatusReport>() {
    UpgradeStatusReport call(int r) throws IOException {
      return namenode.distributedUpgradeProgress(action);
    }
  }).callFS();
}
项目：RDFS    文件：JspHelper.java    
public String getUpgradeStatusText() {
  String statusText = "";
  try {
    UpgradeStatusReport status = 
      fsn.distributedUpgradeProgress(UpgradeAction.GET_STATUS);
    statusText = (status == null ? 
        "There are no upgrades in progress." :
          status.getStatusText(false));
  } catch(IOException e) {
    statusText = "Upgrade status unknown.";
  }
  return statusText;
}
项目：RDFS    文件：DFSAdmin.java    
/**
 * Command to request current distributed upgrade status, 
 * a detailed status, or to force the upgrade to proceed.
 * 
 * Usage: java DFSAdmin -upgradeProgress [status | details | force]
 * @exception IOException 
 */
public int upgradeProgress(String[] argv, int idx) throws IOException {
  DistributedFileSystem dfs = getDFS();
  if (dfs == null) {
    System.out.println("FileSystem is " + getFS().getUri());
    return -1;
  }
  if (idx != argv.length - 1) {
    printUsage("-upgradeProgress");
    return -1;
  }

  UpgradeAction action;
  if ("status".equalsIgnoreCase(argv[idx])) {
    action = UpgradeAction.GET_STATUS;
  } else if ("details".equalsIgnoreCase(argv[idx])) {
    action = UpgradeAction.DETAILED_STATUS;
  } else if ("force".equalsIgnoreCase(argv[idx])) {
    action = UpgradeAction.FORCE_PROCEED;
  } else {
    printUsage("-upgradeProgress");
    return -1;
  }

  UpgradeStatusReport status = dfs.distributedUpgradeProgress(action);
  String statusText = (status == null ? 
      "There are no upgrades in progress." :
        status.getStatusText(action == UpgradeAction.DETAILED_STATUS));
  System.out.println(statusText);
  return 0;
}
项目：hadoop-0.20    文件：JspHelper.java    
public String getUpgradeStatusText() {
  String statusText = "";
  try {
    UpgradeStatusReport status = 
      fsn.distributedUpgradeProgress(UpgradeAction.GET_STATUS);
    statusText = (status == null ? 
        "There are no upgrades in progress." :
          status.getStatusText(false));
  } catch(IOException e) {
    statusText = "Upgrade status unknown.";
  }
  return statusText;
}
项目：hadoop-0.20    文件：DFSAdmin.java    
/**
 * Command to request current distributed upgrade status, 
 * a detailed status, or to force the upgrade to proceed.
 * 
 * Usage: java DFSAdmin -upgradeProgress [status | details | force]
 * @exception IOException 
 */
public int upgradeProgress(String[] argv, int idx) throws IOException {
  if (!(fs instanceof DistributedFileSystem)) {
    System.out.println("FileSystem is " + fs.getUri());
    return -1;
  }
  if (idx != argv.length - 1) {
    printUsage("-upgradeProgress");
    return -1;
  }

  UpgradeAction action;
  if ("status".equalsIgnoreCase(argv[idx])) {
    action = UpgradeAction.GET_STATUS;
  } else if ("details".equalsIgnoreCase(argv[idx])) {
    action = UpgradeAction.DETAILED_STATUS;
  } else if ("force".equalsIgnoreCase(argv[idx])) {
    action = UpgradeAction.FORCE_PROCEED;
  } else {
    printUsage("-upgradeProgress");
    return -1;
  }

  DistributedFileSystem dfs = (DistributedFileSystem) fs;
  UpgradeStatusReport status = dfs.distributedUpgradeProgress(action);
  String statusText = (status == null ? 
      "There are no upgrades in progress." :
        status.getStatusText(action == UpgradeAction.DETAILED_STATUS));
  System.out.println(statusText);
  return 0;
}
项目：hortonworks-extension    文件：JspHelper.java    
public String getUpgradeStatusText() {
  String statusText = "";
  try {
    UpgradeStatusReport status = 
      fsn.distributedUpgradeProgress(UpgradeAction.GET_STATUS);
    statusText = (status == null ? 
        "There are no upgrades in progress." :
          status.getStatusText(false));
  } catch(IOException e) {
    statusText = "Upgrade status unknown.";
  }
  return statusText;
}
项目：hortonworks-extension    文件：DFSAdmin.java    
/**
 * Command to request current distributed upgrade status, 
 * a detailed status, or to force the upgrade to proceed.
 * 
 * Usage: java DFSAdmin -upgradeProgress [status | details | force]
 * @exception IOException 
 */
public int upgradeProgress(String[] argv, int idx) throws IOException {
  if (!(fs instanceof DistributedFileSystem)) {
    System.out.println("FileSystem is " + fs.getUri());
    return -1;
  }
  if (idx != argv.length - 1) {
    printUsage("-upgradeProgress");
    return -1;
  }

  UpgradeAction action;
  if ("status".equalsIgnoreCase(argv[idx])) {
    action = UpgradeAction.GET_STATUS;
  } else if ("details".equalsIgnoreCase(argv[idx])) {
    action = UpgradeAction.DETAILED_STATUS;
  } else if ("force".equalsIgnoreCase(argv[idx])) {
    action = UpgradeAction.FORCE_PROCEED;
  } else {
    printUsage("-upgradeProgress");
    return -1;
  }

  DistributedFileSystem dfs = (DistributedFileSystem) fs;
  UpgradeStatusReport status = dfs.distributedUpgradeProgress(action);
  String statusText = (status == null ? 
      "There are no upgrades in progress." :
        status.getStatusText(action == UpgradeAction.DETAILED_STATUS));
  System.out.println(statusText);
  return 0;
}
项目：hortonworks-extension    文件：JspHelper.java    
public String getUpgradeStatusText() {
  String statusText = "";
  try {
    UpgradeStatusReport status = 
      fsn.distributedUpgradeProgress(UpgradeAction.GET_STATUS);
    statusText = (status == null ? 
        "There are no upgrades in progress." :
          status.getStatusText(false));
  } catch(IOException e) {
    statusText = "Upgrade status unknown.";
  }
  return statusText;
}
项目：hortonworks-extension    文件：DFSAdmin.java    
/**
 * Command to request current distributed upgrade status, 
 * a detailed status, or to force the upgrade to proceed.
 * 
 * Usage: java DFSAdmin -upgradeProgress [status | details | force]
 * @exception IOException 
 */
public int upgradeProgress(String[] argv, int idx) throws IOException {
  if (!(fs instanceof DistributedFileSystem)) {
    System.out.println("FileSystem is " + fs.getUri());
    return -1;
  }
  if (idx != argv.length - 1) {
    printUsage("-upgradeProgress");
    return -1;
  }

  UpgradeAction action;
  if ("status".equalsIgnoreCase(argv[idx])) {
    action = UpgradeAction.GET_STATUS;
  } else if ("details".equalsIgnoreCase(argv[idx])) {
    action = UpgradeAction.DETAILED_STATUS;
  } else if ("force".equalsIgnoreCase(argv[idx])) {
    action = UpgradeAction.FORCE_PROCEED;
  } else {
    printUsage("-upgradeProgress");
    return -1;
  }

  DistributedFileSystem dfs = (DistributedFileSystem) fs;
  UpgradeStatusReport status = dfs.distributedUpgradeProgress(action);
  String statusText = (status == null ? 
      "There are no upgrades in progress." :
        status.getStatusText(action == UpgradeAction.DETAILED_STATUS));
  System.out.println(statusText);
  return 0;
}
项目：hadoop-gpu    文件：JspHelper.java    
public String getUpgradeStatusText() {
  String statusText = "";
  try {
    UpgradeStatusReport status = 
      fsn.distributedUpgradeProgress(UpgradeAction.GET_STATUS);
    statusText = (status == null ? 
        "There are no upgrades in progress." :
          status.getStatusText(false));
  } catch(IOException e) {
    statusText = "Upgrade status unknown.";
  }
  return statusText;
}
项目：hadoop-gpu    文件：DFSAdmin.java    
/**
 * Command to request current distributed upgrade status, 
 * a detailed status, or to force the upgrade to proceed.
 * 
 * Usage: java DFSAdmin -upgradeProgress [status | details | force]
 * @exception IOException 
 */
public int upgradeProgress(String[] argv, int idx) throws IOException {
  if (!(fs instanceof DistributedFileSystem)) {
    System.out.println("FileSystem is " + fs.getUri());
    return -1;
  }
  if (idx != argv.length - 1) {
    printUsage("-upgradeProgress");
    return -1;
  }

  UpgradeAction action;
  if ("status".equalsIgnoreCase(argv[idx])) {
    action = UpgradeAction.GET_STATUS;
  } else if ("details".equalsIgnoreCase(argv[idx])) {
    action = UpgradeAction.DETAILED_STATUS;
  } else if ("force".equalsIgnoreCase(argv[idx])) {
    action = UpgradeAction.FORCE_PROCEED;
  } else {
    printUsage("-upgradeProgress");
    return -1;
  }

  DistributedFileSystem dfs = (DistributedFileSystem) fs;
  UpgradeStatusReport status = dfs.distributedUpgradeProgress(action);
  String statusText = (status == null ? 
      "There are no upgrades in progress." :
        status.getStatusText(action == UpgradeAction.DETAILED_STATUS));
  System.out.println(statusText);
  return 0;
}
项目：hadoop-EAR    文件：DFSClient.java    
/**
 * @see ClientProtocol#distributedUpgradeProgress(FSConstants.UpgradeAction)
 */
public UpgradeStatusReport distributedUpgradeProgress(UpgradeAction action
                                                      ) throws IOException {
  return namenode.distributedUpgradeProgress(action);
}
项目：hadoop-EAR    文件：DistributedFileSystem.java    
public UpgradeStatusReport distributedUpgradeProgress(UpgradeAction action
) throws IOException {
  return dfs.distributedUpgradeProgress(action);
}
项目：hadoop-EAR    文件：NameNode.java    
public UpgradeStatusReport distributedUpgradeProgress(UpgradeAction action
                                                      ) throws IOException {
  return namesystem.distributedUpgradeProgress(action);
}
项目：hadoop-EAR    文件：FSNamesystem.java    
UpgradeStatusReport distributedUpgradeProgress(UpgradeAction action
) throws IOException {
  return upgradeManager.distributedUpgradeProgress(action);
}
项目：hadoop-EAR    文件：ChecksumDistributedFileSystem.java    
public UpgradeStatusReport distributedUpgradeProgress(UpgradeAction action
                                                      ) throws IOException {
  return getDFS().distributedUpgradeProgress(action);
}
项目：hadoop-on-lustre    文件：DFSClient.java    
/**
 * @see ClientProtocol#distributedUpgradeProgress(FSConstants.UpgradeAction)
 */
public UpgradeStatusReport distributedUpgradeProgress(UpgradeAction action
                                                      ) throws IOException {
  return namenode.distributedUpgradeProgress(action);
}
项目：hadoop-on-lustre    文件：DistributedFileSystem.java    
public UpgradeStatusReport distributedUpgradeProgress(UpgradeAction action
) throws IOException {
  return dfs.distributedUpgradeProgress(action);
}
项目：hadoop-on-lustre    文件：NameNode.java    
public UpgradeStatusReport distributedUpgradeProgress(UpgradeAction action
                                                      ) throws IOException {
  return namesystem.distributedUpgradeProgress(action);
}
项目：hadoop-on-lustre    文件：FSNamesystem.java    
UpgradeStatusReport distributedUpgradeProgress(UpgradeAction action 
                                               ) throws IOException {
  return upgradeManager.distributedUpgradeProgress(action);
}
项目：hadoop-on-lustre    文件：ChecksumDistributedFileSystem.java    
public UpgradeStatusReport distributedUpgradeProgress(UpgradeAction action
                                                      ) throws IOException {
  return getDFS().distributedUpgradeProgress(action);
}
项目：cumulus    文件：DFSClient.java    
/**
 * @see ClientProtocol#distributedUpgradeProgress(FSConstants.UpgradeAction)
 */
public UpgradeStatusReport distributedUpgradeProgress(UpgradeAction action)
    throws IOException {
  return namenode.distributedUpgradeProgress(action);
}
项目：cumulus    文件：DistributedFileSystem.java    
public UpgradeStatusReport distributedUpgradeProgress(UpgradeAction action
) throws IOException {
  return dfs.distributedUpgradeProgress(action);
}
项目：cumulus    文件：NameNode.java    
public UpgradeStatusReport distributedUpgradeProgress(UpgradeAction action)
    throws IOException {
  return namesystem.distributedUpgradeProgress(action);
}
项目：cumulus    文件：FSNamesystem.java    
UpgradeStatusReport distributedUpgradeProgress(UpgradeAction action 
                                               ) throws IOException {
  return upgradeManager.distributedUpgradeProgress(action);
}