Java 类org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicyWithNodeGroup 实例源码

项目：hadoop 文件：TestBalancerWithNodeGroup.java

static Configuration createConf() {
  Configuration conf = new HdfsConfiguration();
  TestBalancer.initConf(conf);
  conf.setLong(DFSConfigKeys.DFS_BLOCK_SIZE_KEY, DEFAULT_BLOCK_SIZE);
  conf.set(CommonConfigurationKeysPublic.NET_TOPOLOGY_IMPL_KEY, 
      NetworkTopologyWithNodeGroup.class.getName());
  conf.set(DFSConfigKeys.DFS_BLOCK_REPLICATOR_CLASSNAME_KEY, 
      BlockPlacementPolicyWithNodeGroup.class.getName());
  return conf;
}

项目：aliyun-oss-hadoop-fs 文件：TestBalancerWithNodeGroup.java

static Configuration createConf() {
  Configuration conf = new HdfsConfiguration();
  TestBalancer.initConf(conf);
  conf.setLong(DFSConfigKeys.DFS_BLOCK_SIZE_KEY, DEFAULT_BLOCK_SIZE);
  conf.set(CommonConfigurationKeysPublic.NET_TOPOLOGY_IMPL_KEY, 
      NetworkTopologyWithNodeGroup.class.getName());
  conf.set(DFSConfigKeys.DFS_BLOCK_REPLICATOR_CLASSNAME_KEY, 
      BlockPlacementPolicyWithNodeGroup.class.getName());
  return conf;
}

项目：big-c 文件：TestBalancerWithNodeGroup.java

static Configuration createConf() {
  Configuration conf = new HdfsConfiguration();
  TestBalancer.initConf(conf);
  conf.setLong(DFSConfigKeys.DFS_BLOCK_SIZE_KEY, DEFAULT_BLOCK_SIZE);
  conf.set(CommonConfigurationKeysPublic.NET_TOPOLOGY_IMPL_KEY, 
      NetworkTopologyWithNodeGroup.class.getName());
  conf.set(DFSConfigKeys.DFS_BLOCK_REPLICATOR_CLASSNAME_KEY, 
      BlockPlacementPolicyWithNodeGroup.class.getName());
  return conf;
}

项目：hadoop-2.6.0-cdh5.4.3 文件：TestBalancerWithNodeGroup.java

static Configuration createConf() {
  Configuration conf = new HdfsConfiguration();
  TestBalancer.initConf(conf);
  conf.setLong(DFSConfigKeys.DFS_BLOCK_SIZE_KEY, DEFAULT_BLOCK_SIZE);
  conf.set(CommonConfigurationKeysPublic.NET_TOPOLOGY_IMPL_KEY, 
      NetworkTopologyWithNodeGroup.class.getName());
  conf.set(DFSConfigKeys.DFS_BLOCK_REPLICATOR_CLASSNAME_KEY, 
      BlockPlacementPolicyWithNodeGroup.class.getName());
  return conf;
}

项目：FlexMap 文件：TestBalancerWithNodeGroup.java

static Configuration createConf() {
  Configuration conf = new HdfsConfiguration();
  TestBalancer.initConf(conf);
  conf.setLong(DFSConfigKeys.DFS_BLOCK_SIZE_KEY, DEFAULT_BLOCK_SIZE);
  conf.set(CommonConfigurationKeysPublic.NET_TOPOLOGY_IMPL_KEY, 
      NetworkTopologyWithNodeGroup.class.getName());
  conf.set(DFSConfigKeys.DFS_BLOCK_REPLICATOR_CLASSNAME_KEY, 
      BlockPlacementPolicyWithNodeGroup.class.getName());
  return conf;
}

项目：hadoop-on-lustre2 文件：TestBalancerWithNodeGroup.java

static Configuration createConf() {
  Configuration conf = new HdfsConfiguration();
  TestBalancer.initConf(conf);
  conf.set(CommonConfigurationKeysPublic.NET_TOPOLOGY_IMPL_KEY, 
      NetworkTopologyWithNodeGroup.class.getName());
  conf.set(DFSConfigKeys.DFS_BLOCK_REPLICATOR_CLASSNAME_KEY, 
      BlockPlacementPolicyWithNodeGroup.class.getName());
  return conf;
}