Java StartupProgressView类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.apache.hadoop.hdfs.server.namenode.startupprogress.StartupProgressView类的典型用法代码示例。如果您正苦于以下问题：Java StartupProgressView类的具体用法？Java StartupProgressView怎么用？Java StartupProgressView使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

StartupProgressView类属于org.apache.hadoop.hdfs.server.namenode.startupprogress包，在下文中一共展示了StartupProgressView类的6个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: getMetrics

import org.apache.hadoop.hdfs.server.namenode.startupprogress.StartupProgressView; //导入依赖的package包/类
@Override
public void getMetrics(MetricsCollector collector, boolean all) {
  StartupProgressView prog = startupProgress.createView();
  MetricsRecordBuilder builder = collector.addRecord(
    STARTUP_PROGRESS_METRICS_INFO);

  builder.addCounter(info("ElapsedTime", "overall elapsed time"),
    prog.getElapsedTime());
  builder.addGauge(info("PercentComplete", "overall percent complete"),
    prog.getPercentComplete());

  for (Phase phase: prog.getPhases()) {
    addCounter(builder, phase, "Count", " count", prog.getCount(phase));
    addCounter(builder, phase, "ElapsedTime", " elapsed time",
      prog.getElapsedTime(phase));
    addCounter(builder, phase, "Total", " total", prog.getTotal(phase));
    addGauge(builder, phase, "PercentComplete", " percent complete",
      prog.getPercentComplete(phase));
  }
}

开发者ID:naver，项目名称:hadoop，代码行数:21，代码来源:StartupProgressMetrics.java

示例2: printPhase

import org.apache.hadoop.hdfs.server.namenode.startupprogress.StartupProgressView; //导入依赖的package包/类
/**
 * Prints one line of content for a phase in the Startup Progress report.
 * 
 * @param fout FormattedWriter to receive output
 * @param view StartupProgressView containing information to print
 * @param phase Phase to print
 * @throws IOException thrown if there is an I/O error
 */
private void printPhase(FormattedWriter fout, StartupProgressView view,
    Phase phase) throws IOException {
  StringBuilder phaseLine = new StringBuilder();
  phaseLine.append(phase.getDescription());
  String file = view.getFile(phase);
  if (file != null) {
    phaseLine.append(" ").append(file);
  }
  long size = view.getSize(phase);
  if (size != Long.MIN_VALUE) {
    phaseLine.append(" (").append(StringUtils.byteDesc(size)).append(")");
  }
  fout.println("<td class=\"startupdesc\">%s</td>", phaseLine.toString());
  fout.println("<td>%s</td>", StringUtils.formatPercent(
    view.getPercentComplete(phase), 2));
  fout.println("<td>%s</td>", view.getStatus(phase) == Status.PENDING ? "" :
    StringUtils.formatTime(view.getElapsedTime(phase)));
}

开发者ID:Nextzero，项目名称:hadoop-2.6.0-cdh5.4.3，代码行数:27，代码来源:NamenodeJspHelper.java

示例3: printStep

import org.apache.hadoop.hdfs.server.namenode.startupprogress.StartupProgressView; //导入依赖的package包/类
/**
 * Prints one line of content for a step in the Startup Progress report.
 * 
 * @param fout FormattedWriter to receive output
 * @param view StartupProgressView containing information to print
 * @param phase Phase to print
 * @param step Step to print
 * @throws IOException thrown if there is an I/O error
 */
private void printStep(FormattedWriter fout, StartupProgressView view,
    Phase phase, Step step) throws IOException {
  StringBuilder stepLine = new StringBuilder();
  String file = step.getFile();
  if (file != null) {
    stepLine.append(file);
  }
  long size = step.getSize();
  if (size != Long.MIN_VALUE) {
    stepLine.append(" (").append(StringUtils.byteDesc(size)).append(")");
  }
  StepType type = step.getType();
  if (type != null) {
    stepLine.append(" ").append(type.getDescription());
  }

  fout.println("<td class=\"startupdesc\">%s (%d/%d)</td>",
    stepLine.toString(), view.getCount(phase, step),
    view.getTotal(phase, step));
  fout.println("<td>%s</td>", StringUtils.formatPercent(
    view.getPercentComplete(phase), 2));
  fout.println("<td>%s</td>", view.getStatus(phase) == Status.PENDING ? "" :
    StringUtils.formatTime(view.getElapsedTime(phase)));
}

开发者ID:Nextzero，项目名称:hadoop-2.6.0-cdh5.4.3，代码行数:34，代码来源:NamenodeJspHelper.java

示例4: generateStartupProgress

import org.apache.hadoop.hdfs.server.namenode.startupprogress.StartupProgressView; //导入依赖的package包/类
/**
 * Generates the Startup Progress report.
 * 
 * @param out JspWriter to receive output
 * @param prog StartupProgress tracking NameNode startup progress
 * @throws IOException thrown if there is an I/O error
 */
void generateStartupProgress(JspWriter out, StartupProgress prog)
    throws IOException {
  StartupProgressView view = prog.createView();
  FormattedWriter fout = new FormattedWriter(out);
  fout.println("<div id=\"startupprogress\">");
  fout.println("<div><span>Elapsed Time:</span> %s</div>",
    StringUtils.formatTime(view.getElapsedTime()));
  fout.println("<div><span>Percent Complete:</span> %s</div>",
    StringUtils.formatPercent(view.getPercentComplete(), 2));
  fout.println("<table>");
  fout.println("<tr>");
  fout.println("<th>Phase</th>");
  fout.println("<th>Completion</th>");
  fout.println("<th>Elapsed Time</th>");
  fout.println("</tr>");
  for (Phase phase: view.getPhases()) {
    final String timeClass;
    Status status = view.getStatus(phase);
    if (status == Status.PENDING) {
      timeClass = "later";
    } else if (status == Status.RUNNING) {
      timeClass = "current";
    } else {
      timeClass = "prior";
    }

    fout.println("<tr class=\"phase %s\">", timeClass);
    printPhase(fout, view, phase);
    fout.println("</tr>");

    for (Step step: view.getSteps(phase)) {
      fout.println("<tr class=\"step %s\">", timeClass);
      printStep(fout, view, phase, step);
      fout.println("</tr>");
    }
  }
  fout.println("</table>");
  fout.println("</div>");
}

开发者ID:Nextzero，项目名称:hadoop-2.6.0-cdh5.4.3，代码行数:47，代码来源:NamenodeJspHelper.java

示例5: doGet

import org.apache.hadoop.hdfs.server.namenode.startupprogress.StartupProgressView; //导入依赖的package包/类
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp)
    throws IOException {
  resp.setContentType("application/json; charset=UTF-8");
  StartupProgress prog = NameNodeHttpServer.getStartupProgressFromContext(
    getServletContext());
  StartupProgressView view = prog.createView();
  JsonGenerator json = new JsonFactory().createJsonGenerator(resp.getWriter());
  try {
    json.writeStartObject();
    json.writeNumberField(ELAPSED_TIME, view.getElapsedTime());
    json.writeNumberField(PERCENT_COMPLETE, view.getPercentComplete());
    json.writeArrayFieldStart(PHASES);

    for (Phase phase: view.getPhases()) {
      json.writeStartObject();
      json.writeStringField(NAME, phase.getName());
      json.writeStringField(DESC, phase.getDescription());
      json.writeStringField(STATUS, view.getStatus(phase).toString());
      json.writeNumberField(PERCENT_COMPLETE, view.getPercentComplete(phase));
      json.writeNumberField(ELAPSED_TIME, view.getElapsedTime(phase));
      writeStringFieldIfNotNull(json, FILE, view.getFile(phase));
      writeNumberFieldIfDefined(json, SIZE, view.getSize(phase));
      json.writeArrayFieldStart(STEPS);

      for (Step step: view.getSteps(phase)) {
        json.writeStartObject();
        StepType type = step.getType();
        if (type != null) {
          json.writeStringField(NAME, type.getName());
          json.writeStringField(DESC, type.getDescription());
        }
        json.writeNumberField(COUNT, view.getCount(phase, step));
        writeStringFieldIfNotNull(json, FILE, step.getFile());
        writeNumberFieldIfDefined(json, SIZE, step.getSize());
        json.writeNumberField(TOTAL, view.getTotal(phase, step));
        json.writeNumberField(PERCENT_COMPLETE, view.getPercentComplete(phase,
          step));
        json.writeNumberField(ELAPSED_TIME, view.getElapsedTime(phase, step));
        json.writeEndObject();
      }

      json.writeEndArray();
      json.writeEndObject();
    }

    json.writeEndArray();
    json.writeEndObject();
  } finally {
    IOUtils.cleanup(LOG, json);
  }
}

开发者ID:naver，项目名称:hadoop，代码行数:53，代码来源:StartupProgressServlet.java

示例6: doGet

import org.apache.hadoop.hdfs.server.namenode.startupprogress.StartupProgressView; //导入依赖的package包/类
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp)
    throws IOException {
  resp.setContentType("application/json; charset=UTF-8");
  StartupProgress prog = NameNodeHttpServer.getStartupProgressFromContext(
    getServletContext());
  StartupProgressView view = prog.createView();
  JsonGenerator json = new JsonFactory().createJsonGenerator(resp.getWriter());
  try {
    json.writeStartObject();
    json.writeNumberField(ELAPSED_TIME, view.getElapsedTime());
    json.writeNumberField(PERCENT_COMPLETE, view.getPercentComplete());
    json.writeArrayFieldStart(PHASES);

    for (Phase phase: view.getPhases()) {
      json.writeStartObject();
      json.writeStringField(NAME, phase.getName());
      json.writeStringField(STATUS, view.getStatus(phase).toString());
      json.writeNumberField(PERCENT_COMPLETE, view.getPercentComplete(phase));
      json.writeNumberField(ELAPSED_TIME, view.getElapsedTime(phase));
      writeStringFieldIfNotNull(json, FILE, view.getFile(phase));
      writeNumberFieldIfDefined(json, SIZE, view.getSize(phase));
      json.writeArrayFieldStart(STEPS);

      for (Step step: view.getSteps(phase)) {
        json.writeStartObject();
        StepType type = step.getType();
        String name = type != null ? type.getName() : null;
        writeStringFieldIfNotNull(json, NAME, name);
        json.writeNumberField(COUNT, view.getCount(phase, step));
        writeStringFieldIfNotNull(json, FILE, step.getFile());
        writeNumberFieldIfDefined(json, SIZE, step.getSize());
        json.writeNumberField(TOTAL, view.getTotal(phase, step));
        json.writeNumberField(PERCENT_COMPLETE, view.getPercentComplete(phase,
          step));
        json.writeNumberField(ELAPSED_TIME, view.getElapsedTime(phase, step));
        json.writeEndObject();
      }

      json.writeEndArray();
      json.writeEndObject();
    }

    json.writeEndArray();
    json.writeEndObject();
  } finally {
    IOUtils.cleanup(LOG, json);
  }
}

开发者ID:ict-carch，项目名称:hadoop-plus，代码行数:50，代码来源:StartupProgressServlet.java

注：本文中的org.apache.hadoop.hdfs.server.namenode.startupprogress.StartupProgressView类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java AccessibleRelationSet类代码示例发布时间：2022-05-22

Java StreamDefinition类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18247|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9669|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8175|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8547|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8454|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9383|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8426|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7859|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8410|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7394|2022-11-06

客服电话

电子邮件

Java StartupProgressView类代码示例

示例1: getMetrics

示例2: printPhase

示例3: printStep

示例4: generateStartupProgress

示例5: doGet

示例6: doGet

请发表评论

全部评论

上一篇：

下一篇：

PacktPublishing/Python-Machine-Learning-

BentoBoxWorld/AOneBlock: A OneBlock Mine

鲁东大学一米网:Win7系统USB驱动器RAM的操

manur/MATLAB-git: A thin MATLAB wrapper

nstudio/nativescript-cardview: NativeScr

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053