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));
}