Java SLSWebApp类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

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

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

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

示例1: initMetrics

import org.apache.hadoop.yarn.sls.web.SLSWebApp; //导入依赖的package包/类
@SuppressWarnings("unchecked")
private void initMetrics() throws Exception {
  metrics = new MetricRegistry();
  // configuration
  metricsOutputDir = conf.get(SLSConfiguration.METRICS_OUTPUT_DIR);
  int metricsWebAddressPort = conf.getInt(
          SLSConfiguration.METRICS_WEB_ADDRESS_PORT,
          SLSConfiguration.METRICS_WEB_ADDRESS_PORT_DEFAULT);
  // create SchedulerMetrics for current scheduler
  String schedulerMetricsType = conf.get(scheduler.getClass().getName());
  Class schedulerMetricsClass = schedulerMetricsType == null?
          defaultSchedulerMetricsMap.get(scheduler.getClass()) :
          Class.forName(schedulerMetricsType);
  schedulerMetrics = (SchedulerMetrics)ReflectionUtils
          .newInstance(schedulerMetricsClass, new Configuration());
  schedulerMetrics.init(scheduler, metrics);

  // register various metrics
  registerJvmMetrics();
  registerClusterResourceMetrics();
  registerContainerAppNumMetrics();
  registerSchedulerMetrics();

  // .csv output
  initMetricsCSVOutput();

  // start web app to provide real-time tracking
  web = new SLSWebApp(this, metricsWebAddressPort);
  web.start();

  // a thread to update histogram timer
  pool = new ScheduledThreadPoolExecutor(2);
  pool.scheduleAtFixedRate(new HistogramsRunnable(), 0, 1000,
          TimeUnit.MILLISECONDS);

  // a thread to output metrics for real-tiem tracking
  pool.scheduleAtFixedRate(new MetricsLogRunnable(), 0, 1000,
          TimeUnit.MILLISECONDS);

  // application running information
  jobRuntimeLogBW = new BufferedWriter(
          new FileWriter(metricsOutputDir + "/jobruntime.csv"));
  jobRuntimeLogBW.write("JobID,real_start_time,real_end_time," +
          "simulate_start_time,simulate_end_time" + EOL);
  jobRuntimeLogBW.flush();
}

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

示例2: initMetrics

import org.apache.hadoop.yarn.sls.web.SLSWebApp; //导入依赖的package包/类
@SuppressWarnings("unchecked")
private void initMetrics() throws Exception {
  metrics = new MetricRegistry();
  // configuration
  metricsOutputDir = conf.get(SLSConfiguration.METRICS_OUTPUT_DIR);
  int metricsWebAddressPort = conf.getInt(
          SLSConfiguration.METRICS_WEB_ADDRESS_PORT,
          SLSConfiguration.METRICS_WEB_ADDRESS_PORT_DEFAULT);
  // create SchedulerMetrics for current scheduler
  String schedulerMetricsType = conf.get(scheduler.getClass().getName());
  Class schedulerMetricsClass = schedulerMetricsType == null?
          defaultSchedulerMetricsMap.get(scheduler.getClass()) :
          Class.forName(schedulerMetricsType);
  schedulerMetrics = (SchedulerMetrics)ReflectionUtils
          .newInstance(schedulerMetricsClass, new Configuration());
  schedulerMetrics.init(scheduler, metrics);

  // register various metrics
  registerJvmMetrics();
  registerClusterResourceMetrics();
  registerContainerAppNumMetrics();
  registerSchedulerMetrics();

  // .csv output
  initMetricsCSVOutput();

  // start web app to provide real-time tracking
  web = new SLSWebApp(this, metricsWebAddressPort);
  web.start();

  // a thread to update histogram timer
  pool = new ScheduledThreadPoolExecutor(2);
  pool.scheduleAtFixedRate(new HistogramsRunnable(), 0, 1000,
          TimeUnit.MILLISECONDS);

  // a thread to output metrics for real-tiem tracking
  pool.scheduleAtFixedRate(new MetricsLogRunnable(), 0, 1000,
          TimeUnit.MILLISECONDS);

  // application running information
  jobRuntimeLogBW =
      new BufferedWriter(new OutputStreamWriter(new FileOutputStream(
          metricsOutputDir + "/jobruntime.csv"), "UTF-8"));
  jobRuntimeLogBW.write("JobID,real_start_time,real_end_time," +
          "simulate_start_time,simulate_end_time" + EOL);
  jobRuntimeLogBW.flush();
}

开发者ID:aliyun-beta，项目名称:aliyun-oss-hadoop-fs，代码行数:48，代码来源:ResourceSchedulerWrapper.java

示例3: initMetrics

import org.apache.hadoop.yarn.sls.web.SLSWebApp; //导入依赖的package包/类
@SuppressWarnings({ "unchecked", "rawtypes" })
private void initMetrics() throws Exception {
  metrics = new MetricRegistry();
  // configuration
  metricsOutputDir = conf.get(SLSConfiguration.METRICS_OUTPUT_DIR);
  int metricsWebAddressPort = conf.getInt(
          SLSConfiguration.METRICS_WEB_ADDRESS_PORT,
          SLSConfiguration.METRICS_WEB_ADDRESS_PORT_DEFAULT);
  // create SchedulerMetrics for current scheduler
  String schedulerMetricsType = conf.get(CapacityScheduler.class.getName());
  Class schedulerMetricsClass = schedulerMetricsType == null?
          defaultSchedulerMetricsMap.get(CapacityScheduler.class) :
          Class.forName(schedulerMetricsType);
  schedulerMetrics = (SchedulerMetrics)ReflectionUtils
          .newInstance(schedulerMetricsClass, new Configuration());
  schedulerMetrics.init(this, metrics);

  // register various metrics
  registerJvmMetrics();
  registerClusterResourceMetrics();
  registerContainerAppNumMetrics();
  registerSchedulerMetrics();

  // .csv output
  initMetricsCSVOutput();

  // start web app to provide real-time tracking
  web = new SLSWebApp(this, metricsWebAddressPort);
  web.start();

  // a thread to update histogram timer
  pool = new ScheduledThreadPoolExecutor(2);
  pool.scheduleAtFixedRate(new HistogramsRunnable(), 0, 1000,
          TimeUnit.MILLISECONDS);

  // a thread to output metrics for real-tiem tracking
  pool.scheduleAtFixedRate(new MetricsLogRunnable(), 0, 1000,
          TimeUnit.MILLISECONDS);

  // application running information
  jobRuntimeLogBW =
      new BufferedWriter(new OutputStreamWriter(new FileOutputStream(
          metricsOutputDir + "/jobruntime.csv"), "UTF-8"));
  jobRuntimeLogBW.write("JobID,real_start_time,real_end_time," +
          "simulate_start_time,simulate_end_time" + EOL);
  jobRuntimeLogBW.flush();
}

开发者ID:aliyun-beta，项目名称:aliyun-oss-hadoop-fs，代码行数:48，代码来源:SLSCapacityScheduler.java

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