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(),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(),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(),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(),nnUri));
}