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

YarnConfiguration.timelineServiceEnabled介绍

[英]Returns whether the timeline service is enabled via configuration.
[中]返回是否通过配置启用时间线服务。

代码示例

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-api

/**
 * Returns whether the timeline service v.1 is enabled via configuration.
 *
 * @param conf the configuration
 * @return whether the timeline service v.1 is enabled. V.1 refers to a
 * version greater than equal to 1 but smaller than 2.
 */
public static boolean timelineServiceV1Enabled(Configuration conf) {
 boolean enabled = false;
 if (timelineServiceEnabled(conf)) {
  Collection<Float> versions = getTimelineServiceVersions(conf);
  for (Float version : versions) {
   if (version.intValue() == 1) {
    enabled = true;
    break;
   }
  }
 }
 return enabled;
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-api

/**
 * Returns whether the timeline service v.1,5 is enabled via configuration.
 *
 * @param conf the configuration
 * @return whether the timeline service v.1.5 is enabled. V.1.5 refers to a
 * version equal to 1.5.
 */
public static boolean timelineServiceV15Enabled(Configuration conf) {
 boolean enabled = false;
 if (timelineServiceEnabled(conf)) {
  Collection<Float> versions = getTimelineServiceVersions(conf);
  for (Float version : versions) {
   if (Float.compare(version, 1.5f) == 0) {
    enabled = true;
    break;
   }
  }
 }
 return enabled;
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-api

/**
 * Returns whether the timeline service v.2 is enabled via configuration.
 *
 * @param conf the configuration
 * @return whether the timeline service v.2 is enabled. V.2 refers to a
 * version greater than equal to 2 but smaller than 3.
 */
public static boolean timelineServiceV2Enabled(Configuration conf) {
 boolean enabled = false;
 if (timelineServiceEnabled(conf)) {
  Collection<Float> versions = getTimelineServiceVersions(conf);
  for (Float version : versions) {
   if (version.intValue() == 2) {
    enabled = true;
    break;
   }
  }
 }
 return enabled;
}

代码示例来源：origin: org.apache.hadoop/hadoop-mapreduce-client-app

public RunningAppContext(Configuration config,
  TaskAttemptFinishingMonitor taskAttemptFinishingMonitor) {
 this.conf = config;
 this.clientToAMTokenSecretManager =
   new ClientToAMTokenSecretManager(appAttemptID, null);
 this.taskAttemptFinishingMonitor = taskAttemptFinishingMonitor;
 if (conf.getBoolean(MRJobConfig.MAPREDUCE_JOB_EMIT_TIMELINE_DATA,
     MRJobConfig.DEFAULT_MAPREDUCE_JOB_EMIT_TIMELINE_DATA)
    && YarnConfiguration.timelineServiceEnabled(conf)) {
  if (YarnConfiguration.timelineServiceV2Enabled(conf)) {
   // create new version TimelineClient
   timelineV2Client = TimelineV2Client.createTimelineClient(
     appAttemptID.getApplicationId());
  } else {
   timelineClient = TimelineClient.createTimelineClient();
  }
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-applications-distributedshell

containerFailuresValidityInterval = Long.parseLong(
  cliParser.getOptionValue("container_failures_validity_interval", "-1"));
if (!YarnConfiguration.timelineServiceEnabled(conf)) {
 timelineClient = null;
 timelineV2Client = null;

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-applications-distributedshell

@Override
 public Void run() throws Exception {
  if (YarnConfiguration.timelineServiceEnabled(conf)) {
   timelineServiceV1Enabled =
     YarnConfiguration.timelineServiceV1Enabled(conf);
   timelineServiceV2Enabled =
     YarnConfiguration.timelineServiceV2Enabled(conf);
   // Creating the Timeline Client
   if (timelineServiceV1Enabled) {
    timelineClient = TimelineClient.createTimelineClient();
    timelineClient.init(conf);
    timelineClient.start();
    LOG.info("Timeline service V1 client is enabled");
   }
   if (timelineServiceV2Enabled) {
    timelineV2Client = TimelineV2Client.createTimelineClient(
      appAttemptID.getApplicationId());
    timelineV2Client.init(conf);
    timelineV2Client.start();
    LOG.info("Timeline service V2 client is enabled");
   }
  } else {
   timelineClient = null;
   timelineV2Client = null;
   LOG.warn("Timeline service is not enabled");
  }
  return null;
 }
});

代码示例来源：origin: org.apache.hadoop/hadoop-mapreduce-client-app

MRJobConfig.DEFAULT_MAPREDUCE_JOB_EMIT_TIMELINE_DATA)) {
LOG.info("Emitting job history data to the timeline service is enabled");
if (YarnConfiguration.timelineServiceEnabled(conf)) {
 boolean timelineServiceV2Enabled =
   YarnConfiguration.timelineServiceV2Enabled(conf);

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

private void setup(boolean v1Enabled, boolean v2Enabled) {
 Configuration conf = new YarnConfiguration(new Configuration(false));
 Assert.assertFalse(YarnConfiguration.timelineServiceEnabled(conf));
 if (v1Enabled || v2Enabled) {
  conf.setBoolean(YarnConfiguration.TIMELINE_SERVICE_ENABLED, true);
 }
 if (v1Enabled) {
  conf.setFloat(YarnConfiguration.TIMELINE_SERVICE_VERSION, 1.0f);
 }
 if (v2Enabled) {
  conf.setFloat(YarnConfiguration.TIMELINE_SERVICE_VERSION, 2.0f);
  conf.setClass(YarnConfiguration.TIMELINE_SERVICE_WRITER_CLASS,
    FileSystemTimelineWriterImpl.class, TimelineWriter.class);
 }
 if (v1Enabled && v2Enabled) {
  conf.set(YarnConfiguration.TIMELINE_SERVICE_VERSION, "1.0");
  conf.set(YarnConfiguration.TIMELINE_SERVICE_VERSIONS, "1.0,2.0f");
 }
 MemoryRMStateStore memStore = new MemoryRMStateStore();
 memStore.init(conf);
 rm = new MockRM(conf, memStore);
 rm.start();
}