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

项目:hadoop    文件:TestDFSClientFailover.java   
/**
 * Test to verify IPFailoverProxyProvider is not requiring logical URI.
 */
@Test
public void testIPFailoverProxyProviderLogicalUri() throws Exception {
  // setup the config with the IP failover proxy provider class
  Configuration config = new HdfsConfiguration(conf);
  URI nnUri = cluster.getURI(0);
  config.set(DFS_CLIENT_FAILOVER_PROXY_PROVIDER_KEY_PREFIX + "." +
      nnUri.getHost(),
      IPFailoverProxyProvider.class.getName());

  assertFalse("IPFailoverProxyProvider should not use logical URI.",
      HAUtil.useLogicalUri(config, nnUri));
}
项目:aliyun-oss-hadoop-fs    文件:TestDFSClientFailover.java   
/**
 * Test to verify IPFailoverProxyProvider is not requiring logical URI.
 */
@Test
public void testIPFailoverProxyProviderLogicalUri() throws Exception {
  // setup the config with the IP failover proxy provider class
  Configuration config = new HdfsConfiguration(conf);
  URI nnUri = cluster.getURI(0);
  config.set(HdfsClientConfigKeys.Failover.PROXY_PROVIDER_KEY_PREFIX + "." +
      nnUri.getHost(),
      IPFailoverProxyProvider.class.getName());

  assertFalse("IPFailoverProxyProvider should not use logical URI.",
      HAUtil.useLogicalUri(config, nnUri));
}
项目:big-c    文件:TestDFSClientFailover.java   
/**
 * Test to verify IPFailoverProxyProvider is not requiring logical URI.
 */
@Test
public void testIPFailoverProxyProviderLogicalUri() throws Exception {
  // setup the config with the IP failover proxy provider class
  Configuration config = new HdfsConfiguration(conf);
  URI nnUri = cluster.getURI(0);
  config.set(DFS_CLIENT_FAILOVER_PROXY_PROVIDER_KEY_PREFIX + "." +
      nnUri.getHost(),
      IPFailoverProxyProvider.class.getName());

  assertFalse("IPFailoverProxyProvider should not use logical URI.",
      HAUtil.useLogicalUri(config, nnUri));
}
项目:hadoop-2.6.0-cdh5.4.3    文件:TestDFSClientFailover.java   
/**
 * Test to verify IPFailoverProxyProvider is not requiring logical URI.
 */
@Test
public void testIPFailoverProxyProviderLogicalUri() throws Exception {
  // setup the config with the IP failover proxy provider class
  Configuration config = new HdfsConfiguration(conf);
  URI nnUri = cluster.getURI(0);
  config.set(DFS_CLIENT_FAILOVER_PROXY_PROVIDER_KEY_PREFIX + "." +
      nnUri.getHost(),
      IPFailoverProxyProvider.class.getName());

  assertFalse("IPFailoverProxyProvider should not use logical URI.",
      HAUtil.useLogicalUri(config, nnUri));
}
项目:FlexMap    文件:TestDFSClientFailover.java   
/**
 * Test to verify IPFailoverProxyProvider is not requiring logical URI.
 */
@Test
public void testIPFailoverProxyProviderLogicalUri() throws Exception {
  // setup the config with the IP failover proxy provider class
  Configuration config = new HdfsConfiguration(conf);
  URI nnUri = cluster.getURI(0);
  config.set(DFS_CLIENT_FAILOVER_PROXY_PROVIDER_KEY_PREFIX + "." +
      nnUri.getHost(),
      IPFailoverProxyProvider.class.getName());

  assertFalse("IPFailoverProxyProvider should not use logical URI.",
      HAUtil.useLogicalUri(config, nnUri));
}