gpt4 book ai didi

org.apache.hadoop.yarn.conf.YarnConfiguration.setFloat()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-18 02:08:40 26 4
gpt4 key购买 nike

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

YarnConfiguration.setFloat介绍

暂无

代码示例

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

private YarnConfiguration getConfigurations() {
 YarnConfiguration conf = new YarnConfiguration();
 conf.setBoolean(YarnConfiguration.TIMELINE_SERVICE_ENABLED, true);
 conf.setFloat(YarnConfiguration.TIMELINE_SERVICE_VERSION, 1.5f);
 conf.set(YarnConfiguration.TIMELINE_SERVICE_ENTITYGROUP_FS_STORE_ACTIVE_DIR,
   localActiveDir.getAbsolutePath());
 conf.set(
   YarnConfiguration.TIMELINE_SERVICE_ENTITYGROUP_FS_STORE_SUMMARY_ENTITY_TYPES,
   "summary_type");
 return conf;
}

代码示例来源:origin: io.hops/hadoop-yarn-common

@Before
public void setup() throws Exception {
 localFS = FileContext.getLocalFSFileContext();
 localActiveDir =
   new File("target", this.getClass().getSimpleName() + "-activeDir")
    .getAbsoluteFile();
 localFS.delete(new Path(localActiveDir.getAbsolutePath()), true);
 localActiveDir.mkdir();
 LOG.info("Created activeDir in " + localActiveDir.getAbsolutePath());
 YarnConfiguration conf = new YarnConfiguration();
 conf.setBoolean(YarnConfiguration.TIMELINE_SERVICE_ENABLED, true);
 conf.setFloat(YarnConfiguration.TIMELINE_SERVICE_VERSION, 1.5f);
 conf.set(YarnConfiguration.TIMELINE_SERVICE_ENTITYGROUP_FS_STORE_ACTIVE_DIR,
  localActiveDir.getAbsolutePath());
 conf.set(
  YarnConfiguration.TIMELINE_SERVICE_ENTITYGROUP_FS_STORE_SUMMARY_ENTITY_TYPES,
  "summary_type");
 client = createTimelineClient(conf);
}

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

/**
 * Prepare configuration for plugin tests. This method will also add the mini
 * DFS cluster's info to the configuration.
 * Note: the test program needs to setup the reader plugin by itself.
 *
 * @param conf
 * @param dfsCluster
 * @return the modified configuration
 */
public static YarnConfiguration prepareConfiguration(YarnConfiguration conf,
  MiniDFSCluster dfsCluster) {
 conf.set(CommonConfigurationKeysPublic.FS_DEFAULT_NAME_KEY,
   dfsCluster.getURI().toString());
 conf.setFloat(YarnConfiguration.TIMELINE_SERVICE_VERSION, 1.5f);
 conf.setLong(
   YarnConfiguration.TIMELINE_SERVICE_ENTITYGROUP_FS_STORE_SCAN_INTERVAL_SECONDS,
   1);
 conf.set(YarnConfiguration.TIMELINE_SERVICE_STORE,
   EntityGroupFSTimelineStore.class.getName());
 return conf;
}

代码示例来源:origin: io.hops/hadoop-yarn-common

@Before
public void setup() {
 FileUtil.fullyDelete(testDir);
 testDir.mkdirs();
 YarnConfiguration conf = new YarnConfiguration();
 conf.setBoolean(YarnConfiguration.TIMELINE_SERVICE_ENABLED, true);
 conf.setFloat(YarnConfiguration.TIMELINE_SERVICE_VERSION, 1.0f);
 client = createTimelineClient(conf);
}

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

@Before
public void setup() {
 YarnConfiguration conf = new YarnConfiguration();
 conf.setBoolean(YarnConfiguration.TIMELINE_SERVICE_ENABLED, true);
 conf.setFloat(YarnConfiguration.TIMELINE_SERVICE_VERSION, 1.0f);
 client = createTimelineClient(conf);
}

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

@Before
public void setup() {
 conf = new YarnConfiguration();
 conf.setBoolean(YarnConfiguration.TIMELINE_SERVICE_ENABLED, true);
 conf.setFloat(YarnConfiguration.TIMELINE_SERVICE_VERSION, 2.0f);
 conf.setInt(YarnConfiguration.NUMBER_OF_ASYNC_ENTITIES_TO_MERGE, 3);
 if (!currTestName.getMethodName()
   .contains("testRetryOnConnectionFailure")) {
  client = createTimelineClient(conf);
 }
}

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

getConf().setFloat(
  YarnConfiguration.AM_SCHEDULING_NODE_BLACKLISTING_DISABLE_THRESHOLD,
  0.5f);

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

conf.setBoolean(YarnConfiguration.AM_SCHEDULING_NODE_BLACKLISTING_ENABLED,
  true);
conf.setFloat(
  YarnConfiguration.AM_SCHEDULING_NODE_BLACKLISTING_DISABLE_THRESHOLD,
  0.5f);

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

@Test (timeout = 60000)
public void testRMRestartTimelineCollectorContext() throws Exception {
 conf.setBoolean(YarnConfiguration.TIMELINE_SERVICE_ENABLED, true);
 conf.setFloat(YarnConfiguration.TIMELINE_SERVICE_VERSION, 2.0f);

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

true);
conf.setFloat(
  YarnConfiguration.AM_SCHEDULING_NODE_BLACKLISTING_DISABLE_THRESHOLD,
  1.5f);

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com