Java 类org.apache.hadoop.hdfs.server.namenode.BlockPlacementPolicyDefault 实例源码

@Test
public void testReplicationSimulatedStoragDefault() throws IOException {
  runReplication(true, BlockPlacementPolicyDefault.class);
}

@Test
public void testReplicationDefault() throws IOException {
  runReplication(false, BlockPlacementPolicyDefault.class);
}

@Test
public void testPendingReplicationRetryDefault() throws IOException {
  runPendingReplicationRetry(BlockPlacementPolicyDefault.class);
}

@Test
public void testPendingReplicationRetryInlineChecksum() throws IOException {
  pendingReplicationRetryInternal(true, BlockPlacementPolicyDefault.class);
}

private void checkReplicationPolicyCompatibility(Configuration conf) {
  if (!(BlockPlacementPolicy.getInstance(conf, null, null, null, null, null)
      instanceof BlockPlacementPolicyDefault)) {
    throw new IllegalArgumentException("Configuration lacks BlockPlacementPolicyDefault");
  }
}

private void checkReplicationPolicyCompatibility(Configuration conf) throws UnsupportedActionException {
  if (BlockPlacementPolicy.getInstance(conf, null, null).getClass() != 
      BlockPlacementPolicyDefault.class) {
    throw new UnsupportedActionException("Balancer without BlockPlacementPolicyDefault");
  }
}

private void checkReplicationPolicyCompatibility(Configuration conf) {
  if (!(BlockPlacementPolicy.getInstance(conf, null, null, null, null, null)
      instanceof BlockPlacementPolicyDefault)) {
    throw new IllegalArgumentException("Configuration lacks BlockPlacementPolicyDefault");
  }
}