• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java InputType类代码示例

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

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



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

示例1: render

import org.apache.hadoop.yarn.webapp.hamlet.HamletSpec.InputType; //导入依赖的package包/类
@Override protected void render(Block html) {
  String jid = $(JOB_ID);
  if (jid.isEmpty()) {
    html.
      p()._("Sorry, can't do anything without a JobID.")._();
    return;
  }
  JobId jobID = MRApps.toJobID(jid);
  Job job = appContext.getJob(jobID);
  if (job == null) {
    html.
      p()._("Sorry, ", jid, " not found.")._();
    return;
  }
  Path confPath = job.getConfFile();
  try {
    ConfInfo info = new ConfInfo(job);

    html.div().h3(confPath.toString())._();
    TBODY<TABLE<Hamlet>> tbody = html.
      // Tasks table
    table("#conf").
      thead().
        tr().
          th(_TH, "key").
          th(_TH, "value").
          th(_TH, "source chain").
        _().
      _().
    tbody();
    for (ConfEntryInfo entry : info.getProperties()) {
      StringBuffer buffer = new StringBuffer();
      String[] sources = entry.getSource();
      //Skip the last entry, because it is always the same HDFS file, and
      // output them in reverse order so most recent is output first
      boolean first = true;
      for(int i = (sources.length  - 2); i >= 0; i--) {
        if(!first) {
          // \u2B05 is an arrow <--
          buffer.append(" \u2B05 ");
        }
        first = false;
        buffer.append(sources[i]);
      }
      tbody.
        tr().
          td(entry.getName()).
          td(entry.getValue()).
          td(buffer.toString()).
        _();
    }
    tbody._().
    tfoot().
      tr().
        th().input("search_init").$type(InputType.text).$name("key").$value("key")._()._().
        th().input("search_init").$type(InputType.text).$name("value").$value("value")._()._().
        th().input("search_init").$type(InputType.text).$name("source chain").$value("source chain")._()._().
        _().
      _().
    _();
  } catch(IOException e) {
    LOG.error("Error while reading "+confPath, e);
    html.p()._("Sorry got an error while reading conf file. ",confPath);
  }
}
 
开发者ID:naver,项目名称:hadoop,代码行数:66,代码来源:ConfBlock.java


示例2: render

import org.apache.hadoop.yarn.webapp.hamlet.HamletSpec.InputType; //导入依赖的package包/类
@Override protected void render(Block html) {
  TBODY<TABLE<Hamlet>> tbody = html.
    h2("Retired Jobs").
    table("#jobs").
      thead().
        tr().
          th("Submit Time").
          th("Start Time").
          th("Finish Time").
          th(".id", "Job ID").
          th(".name", "Name").
          th("User").
          th("Queue").
          th(".state", "State").
          th("Maps Total").
          th("Maps Completed").
          th("Reduces Total").
          th("Reduces Completed")._()._().
      tbody();
  LOG.info("Getting list of all Jobs.");
  // Write all the data into a JavaScript array of arrays for JQuery
  // DataTables to display
  StringBuilder jobsTableData = new StringBuilder("[\n");
  for (Job j : appContext.getAllJobs().values()) {
    JobInfo job = new JobInfo(j);
    jobsTableData.append("[\"")
    .append(dateFormat.format(new Date(job.getSubmitTime()))).append("\",\"")
    .append(dateFormat.format(new Date(job.getStartTime()))).append("\",\"")
    .append(dateFormat.format(new Date(job.getFinishTime()))).append("\",\"")
    .append("<a target='_blank' href='").append(url("job", job.getId())).append("'>")
    .append(job.getId()).append("</a>\",\"")
    .append(StringEscapeUtils.escapeJavaScript(StringEscapeUtils.escapeHtml(
      job.getName()))).append("\",\"")
    .append(StringEscapeUtils.escapeJavaScript(StringEscapeUtils.escapeHtml(
      job.getUserName()))).append("\",\"")
    .append(StringEscapeUtils.escapeJavaScript(StringEscapeUtils.escapeHtml(
      job.getQueueName()))).append("\",\"")
    .append(job.getState()).append("\",\"")
    .append(String.valueOf(job.getMapsTotal())).append("\",\"")
    .append(String.valueOf(job.getMapsCompleted())).append("\",\"")
    .append(String.valueOf(job.getReducesTotal())).append("\",\"")
    .append(String.valueOf(job.getReducesCompleted())).append("\"],\n");
  }

  //Remove the last comma and close off the array of arrays
  if(jobsTableData.charAt(jobsTableData.length() - 2) == ',') {
    jobsTableData.delete(jobsTableData.length()-2, jobsTableData.length()-1);
  }
  jobsTableData.append("]");
  html.script().$type("text/javascript").
  _("var jobsTableData=" + jobsTableData)._();
  tbody._().
  tfoot().
    tr().
      th().input("search_init").$type(InputType.text).$name("submit_time").$value("Submit Time")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("Start Time")._()._().
      th().input("search_init").$type(InputType.text).$name("finish_time").$value("Finish Time")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("Job ID")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("Name")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("User")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("Queue")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("State")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("Maps Total")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("Maps Completed")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("Reduces Total")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("Reduces Completed")._()._().
      _().
    _().
  _();
}
 
开发者ID:naver,项目名称:hadoop,代码行数:71,代码来源:HsJobsBlock.java


示例3: render

import org.apache.hadoop.yarn.webapp.hamlet.HamletSpec.InputType; //导入依赖的package包/类
@Override protected void render(Block html) {
  String jid = $(JOB_ID);
  if (jid.isEmpty()) {
    html.
      p()._("Sorry, can't do anything without a JobID.")._();
    return;
  }
  JobId jobID = MRApps.toJobID(jid);
  Job job = appContext.getJob(jobID);
  if (job == null) {
    html.
      p()._("Sorry, ", jid, " not found.")._();
    return;
  }
  Path confPath = job.getConfFile();
  try {
    ConfInfo info = new ConfInfo(job);

    html.div().h3(confPath.toString())._();
    TBODY<TABLE<Hamlet>> tbody = html.
      // Tasks table
    table("#conf").
      thead().
        tr().
          th(_TH, "key").
          th(_TH, "value").
          th(_TH, "source chain").
        _().
      _().
    tbody();
    for (ConfEntryInfo entry : info.getProperties()) {
      StringBuffer buffer = new StringBuffer();
      String[] sources = entry.getSource();
      //Skip the last entry, because it is always the same HDFS file, and
      // output them in reverse order so most recent is output first
      boolean first = true;
      for(int i = (sources.length  - 2); i >= 0; i--) {
        if(!first) {
          buffer.append(" <- ");
        }
        first = false;
        buffer.append(sources[i]);
      }
      tbody.
        tr().
          td(entry.getName()).
          td(entry.getValue()).
          td(buffer.toString()).
        _();
    }
    tbody._().
    tfoot().
      tr().
        th().input("search_init").$type(InputType.text).$name("key").$value("key")._()._().
        th().input("search_init").$type(InputType.text).$name("value").$value("value")._()._().
        th().input("search_init").$type(InputType.text).$name("source chain").$value("source chain")._()._().
        _().
      _().
    _();
  } catch(IOException e) {
    LOG.error("Error while reading "+confPath, e);
    html.p()._("Sorry got an error while reading conf file. ",confPath);
  }
}
 
开发者ID:aliyun-beta,项目名称:aliyun-oss-hadoop-fs,代码行数:65,代码来源:ConfBlock.java


示例4: render

import org.apache.hadoop.yarn.webapp.hamlet.HamletSpec.InputType; //导入依赖的package包/类
@Override protected void render(Block html) {
  TBODY<TABLE<Hamlet>> tbody = html.
    h2("Retired Jobs").
    table("#jobs").
      thead().
        tr().
          th("Submit Time").
          th("Start Time").
          th("Finish Time").
          th(".id", "Job ID").
          th(".name", "Name").
          th("User").
          th("Queue").
          th(".state", "State").
          th("Maps Total").
          th("Maps Completed").
          th("Reduces Total").
          th("Reduces Completed")._()._().
      tbody();
  LOG.info("Getting list of all Jobs.");
  // Write all the data into a JavaScript array of arrays for JQuery
  // DataTables to display
  StringBuilder jobsTableData = new StringBuilder("[\n");
  for (Job j : appContext.getAllJobs().values()) {
    JobInfo job = new JobInfo(j);
    jobsTableData.append("[\"")
    .append(dateFormat.format(new Date(job.getSubmitTime()))).append("\",\"")
    .append(dateFormat.format(new Date(job.getStartTime()))).append("\",\"")
    .append(dateFormat.format(new Date(job.getFinishTime()))).append("\",\"")
    .append("<a href='").append(url("job", job.getId())).append("'>")
    .append(job.getId()).append("</a>\",\"")
    .append(StringEscapeUtils.escapeJavaScript(StringEscapeUtils.escapeHtml(
      job.getName()))).append("\",\"")
    .append(StringEscapeUtils.escapeJavaScript(StringEscapeUtils.escapeHtml(
      job.getUserName()))).append("\",\"")
    .append(StringEscapeUtils.escapeJavaScript(StringEscapeUtils.escapeHtml(
      job.getQueueName()))).append("\",\"")
    .append(job.getState()).append("\",\"")
    .append(String.valueOf(job.getMapsTotal())).append("\",\"")
    .append(String.valueOf(job.getMapsCompleted())).append("\",\"")
    .append(String.valueOf(job.getReducesTotal())).append("\",\"")
    .append(String.valueOf(job.getReducesCompleted())).append("\"],\n");
  }

  //Remove the last comma and close off the array of arrays
  if(jobsTableData.charAt(jobsTableData.length() - 2) == ',') {
    jobsTableData.delete(jobsTableData.length()-2, jobsTableData.length()-1);
  }
  jobsTableData.append("]");
  html.script().$type("text/javascript").
  _("var jobsTableData=" + jobsTableData)._();
  tbody._().
  tfoot().
    tr().
      th().input("search_init").$type(InputType.text).$name("submit_time").$value("Submit Time")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("Start Time")._()._().
      th().input("search_init").$type(InputType.text).$name("finish_time").$value("Finish Time")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("Job ID")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("Name")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("User")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("Queue")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("State")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("Maps Total")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("Maps Completed")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("Reduces Total")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("Reduces Completed")._()._().
      _().
    _().
  _();
}
 
开发者ID:yncxcw,项目名称:big-c,代码行数:71,代码来源:HsJobsBlock.java


示例5: render

import org.apache.hadoop.yarn.webapp.hamlet.HamletSpec.InputType; //导入依赖的package包/类
@Override protected void render(Block html) {
  TBODY<TABLE<Hamlet>> tbody = html.
    h2("Retired Jobs").
    table("#jobs").
      thead().
        tr().
          th("Start Time").
          th("Finish Time").
          th(".id", "Job ID").
          th(".name", "Name").
          th("User").
          th("Queue").
          th(".state", "State").
          th("Maps Total").
          th("Maps Completed").
          th("Reduces Total").
          th("Reduces Completed")._()._().
      tbody();
  LOG.info("Getting list of all Jobs.");
  // Write all the data into a JavaScript array of arrays for JQuery
  // DataTables to display
  StringBuilder jobsTableData = new StringBuilder("[\n");
  for (Job j : appContext.getAllJobs().values()) {
    JobInfo job = new JobInfo(j);
    jobsTableData.append("[\"")
    .append(dateFormat.format(new Date(job.getStartTime()))).append("\",\"")
    .append(dateFormat.format(new Date(job.getFinishTime()))).append("\",\"")
    .append("<a href='").append(url("job", job.getId())).append("'>")
    .append(job.getId()).append("</a>\",\"")
    .append(StringEscapeUtils.escapeJavaScript(StringEscapeUtils.escapeHtml(
      job.getName()))).append("\",\"")
    .append(StringEscapeUtils.escapeJavaScript(StringEscapeUtils.escapeHtml(
      job.getUserName()))).append("\",\"")
    .append(StringEscapeUtils.escapeJavaScript(StringEscapeUtils.escapeHtml(
      job.getQueueName()))).append("\",\"")
    .append(job.getState()).append("\",\"")
    .append(String.valueOf(job.getMapsTotal())).append("\",\"")
    .append(String.valueOf(job.getMapsCompleted())).append("\",\"")
    .append(String.valueOf(job.getReducesTotal())).append("\",\"")
    .append(String.valueOf(job.getReducesCompleted())).append("\"],\n");
  }

  //Remove the last comma and close off the array of arrays
  if(jobsTableData.charAt(jobsTableData.length() - 2) == ',') {
    jobsTableData.delete(jobsTableData.length()-2, jobsTableData.length()-1);
  }
  jobsTableData.append("]");
  html.script().$type("text/javascript").
  _("var jobsTableData=" + jobsTableData)._();
  tbody._().
  tfoot().
    tr().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("Start Time")._()._().
      th().input("search_init").$type(InputType.text).$name("finish_time").$value("Finish Time")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("Job ID")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("Name")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("User")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("Queue")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("State")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("Maps Total")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("Maps Completed")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("Reduces Total")._()._().
      th().input("search_init").$type(InputType.text).$name("start_time").$value("Reduces Completed")._()._().
      _().
    _().
  _();
}
 
开发者ID:ict-carch,项目名称:hadoop-plus,代码行数:68,代码来源:HsJobsBlock.java



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


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java RenewLeaseRequestProto类代码示例发布时间:2022-05-22
下一篇:
Java WSResourceLifetimeServiceAddressingLocator类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap