Java 类org.apache.hadoop.security.protocolPB.RefreshUserMappingsProtocolClientSideTranslatorPB 实例源码

项目：hadoop 文件：HSProxies.java

private static RefreshUserMappingsProtocol createHSProxyWithRefreshUserMappingsProtocol(
    InetSocketAddress address, Configuration conf, UserGroupInformation ugi)
    throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB) createHSProxy(
      address, conf, ugi, RefreshUserMappingsProtocolPB.class, 0);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

项目：hadoop 文件：NameNodeProxies.java

private static RefreshUserMappingsProtocol
    createNNProxyWithRefreshUserMappingsProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshUserMappingsProtocolPB.class);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

项目：hadoop 文件：TestIsMethodSupported.java

@Test
public void testRefreshUserMappingsProtocol() throws IOException {
  RefreshUserMappingsProtocolClientSideTranslatorPB translator =
      (RefreshUserMappingsProtocolClientSideTranslatorPB)
      NameNodeProxies.createNonHAProxy(conf, nnAddress,
          RefreshUserMappingsProtocol.class,
          UserGroupInformation.getCurrentUser(), true).getProxy();
  assertTrue(
      translator.isMethodSupported("refreshUserToGroupsMappings"));
}

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

private static RefreshUserMappingsProtocol createHSProxyWithRefreshUserMappingsProtocol(
    InetSocketAddress address, Configuration conf, UserGroupInformation ugi)
    throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB) createHSProxy(
      address, conf, ugi, RefreshUserMappingsProtocolPB.class, 0);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

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

private static RefreshUserMappingsProtocol
    createNNProxyWithRefreshUserMappingsProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshUserMappingsProtocolPB.class, 0);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

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

@Test
public void testRefreshUserMappingsProtocol() throws IOException {
  RefreshUserMappingsProtocolClientSideTranslatorPB translator =
      (RefreshUserMappingsProtocolClientSideTranslatorPB)
      NameNodeProxies.createNonHAProxy(conf, nnAddress,
          RefreshUserMappingsProtocol.class,
          UserGroupInformation.getCurrentUser(), true).getProxy();
  assertTrue(
      translator.isMethodSupported("refreshUserToGroupsMappings"));
}

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

private static RefreshUserMappingsProtocol createHSProxyWithRefreshUserMappingsProtocol(
    InetSocketAddress address, Configuration conf, UserGroupInformation ugi)
    throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB) createHSProxy(
      address, conf, ugi, RefreshUserMappingsProtocolPB.class, 0);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

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

private static RefreshUserMappingsProtocol
    createNNProxyWithRefreshUserMappingsProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshUserMappingsProtocolPB.class);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

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

@Test
public void testRefreshUserMappingsProtocol() throws IOException {
  RefreshUserMappingsProtocolClientSideTranslatorPB translator =
      (RefreshUserMappingsProtocolClientSideTranslatorPB)
      NameNodeProxies.createNonHAProxy(conf, nnAddress,
          RefreshUserMappingsProtocol.class,
          UserGroupInformation.getCurrentUser(), true).getProxy();
  assertTrue(
      translator.isMethodSupported("refreshUserToGroupsMappings"));
}

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

private static RefreshUserMappingsProtocol createHSProxyWithRefreshUserMappingsProtocol(
    InetSocketAddress address, Configuration conf, UserGroupInformation ugi)
    throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB) createHSProxy(
      address, conf, ugi, RefreshUserMappingsProtocolPB.class, 0);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

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

private static RefreshUserMappingsProtocol
    createNNProxyWithRefreshUserMappingsProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshUserMappingsProtocolPB.class);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

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

@Test
public void testRefreshUserMappingsProtocol() throws IOException {
  RefreshUserMappingsProtocolClientSideTranslatorPB translator =
      (RefreshUserMappingsProtocolClientSideTranslatorPB)
      NameNodeProxies.createNonHAProxy(conf, nnAddress,
          RefreshUserMappingsProtocol.class,
          UserGroupInformation.getCurrentUser(), true).getProxy();
  assertTrue(
      translator.isMethodSupported("refreshUserToGroupsMappings"));
}

项目：hadoop-plus 文件：NameNodeProxies.java

private static RefreshUserMappingsProtocol
    createNNProxyWithRefreshUserMappingsProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshUserMappingsProtocolPB.class);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

项目：hadoop-plus 文件：TestIsMethodSupported.java

@Test
public void testRefreshUserMappingsProtocol() throws IOException {
  RefreshUserMappingsProtocolClientSideTranslatorPB translator =
      (RefreshUserMappingsProtocolClientSideTranslatorPB)
      NameNodeProxies.createNonHAProxy(conf, nnAddress,
          RefreshUserMappingsProtocol.class,
          UserGroupInformation.getCurrentUser(), true).getProxy();
  assertTrue(
      translator.isMethodSupported("refreshUserToGroupsMappings"));
}

项目：FlexMap 文件：HSProxies.java

private static RefreshUserMappingsProtocol createHSProxyWithRefreshUserMappingsProtocol(
    InetSocketAddress address, Configuration conf, UserGroupInformation ugi)
    throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB) createHSProxy(
      address, conf, ugi, RefreshUserMappingsProtocolPB.class, 0);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

项目：FlexMap 文件：NameNodeProxies.java

private static RefreshUserMappingsProtocol
    createNNProxyWithRefreshUserMappingsProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshUserMappingsProtocolPB.class);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

项目：FlexMap 文件：TestIsMethodSupported.java

@Test
public void testRefreshUserMappingsProtocol() throws IOException {
  RefreshUserMappingsProtocolClientSideTranslatorPB translator =
      (RefreshUserMappingsProtocolClientSideTranslatorPB)
      NameNodeProxies.createNonHAProxy(conf, nnAddress,
          RefreshUserMappingsProtocol.class,
          UserGroupInformation.getCurrentUser(), true).getProxy();
  assertTrue(
      translator.isMethodSupported("refreshUserToGroupsMappings"));
}

项目：hops 文件：HSProxies.java

private static RefreshUserMappingsProtocol createHSProxyWithRefreshUserMappingsProtocol(
    InetSocketAddress address, Configuration conf, UserGroupInformation ugi)
    throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB) createHSProxy(
      address, conf, ugi, RefreshUserMappingsProtocolPB.class, 0);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

项目：hops 文件：NameNodeProxies.java

private static RefreshUserMappingsProtocol createNNProxyWithRefreshUserMappingsProtocol(
    InetSocketAddress address, Configuration conf, UserGroupInformation ugi)
    throws IOException {
  RefreshUserMappingsProtocolPB proxy =
      (RefreshUserMappingsProtocolPB) createNameNodeProxy(address, conf, ugi,
          RefreshUserMappingsProtocolPB.class);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

项目：hops 文件：TestIsMethodSupported.java

@Test
public void testRefreshUserMappingsProtocol() throws IOException {
  RefreshUserMappingsProtocolClientSideTranslatorPB translator =
      (RefreshUserMappingsProtocolClientSideTranslatorPB) NameNodeProxies
          .createNonHAProxy(conf, nnAddress,
              RefreshUserMappingsProtocol.class,
              UserGroupInformation.getCurrentUser(), true).getProxy();
  assertTrue(translator.isMethodSupported("refreshUserToGroupsMappings"));
}

项目：hadoop-TCP 文件：NameNodeProxies.java

private static RefreshUserMappingsProtocol
    createNNProxyWithRefreshUserMappingsProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshUserMappingsProtocolPB.class);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

项目：hadoop-TCP 文件：TestIsMethodSupported.java

@Test
public void testRefreshUserMappingsProtocol() throws IOException {
  RefreshUserMappingsProtocolClientSideTranslatorPB translator =
      (RefreshUserMappingsProtocolClientSideTranslatorPB)
      NameNodeProxies.createNonHAProxy(conf, nnAddress,
          RefreshUserMappingsProtocol.class,
          UserGroupInformation.getCurrentUser(), true).getProxy();
  assertTrue(
      translator.isMethodSupported("refreshUserToGroupsMappings"));
}

项目：hardfs 文件：NameNodeProxies.java

private static RefreshUserMappingsProtocol
    createNNProxyWithRefreshUserMappingsProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshUserMappingsProtocolPB.class);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

项目：hardfs 文件：TestIsMethodSupported.java

@Test
public void testRefreshUserMappingsProtocol() throws IOException {
  RefreshUserMappingsProtocolClientSideTranslatorPB translator =
      (RefreshUserMappingsProtocolClientSideTranslatorPB)
      NameNodeProxies.createNonHAProxy(conf, nnAddress,
          RefreshUserMappingsProtocol.class,
          UserGroupInformation.getCurrentUser(), true).getProxy();
  assertTrue(
      translator.isMethodSupported("refreshUserToGroupsMappings"));
}

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

private static RefreshUserMappingsProtocol createHSProxyWithRefreshUserMappingsProtocol(
    InetSocketAddress address, Configuration conf, UserGroupInformation ugi)
    throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB) createHSProxy(
      address, conf, ugi, RefreshUserMappingsProtocolPB.class, 0);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

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

private static RefreshUserMappingsProtocol
    createNNProxyWithRefreshUserMappingsProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshUserMappingsProtocolPB proxy = (RefreshUserMappingsProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshUserMappingsProtocolPB.class);
  return new RefreshUserMappingsProtocolClientSideTranslatorPB(proxy);
}

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

@Test
public void testRefreshUserMappingsProtocol() throws IOException {
  RefreshUserMappingsProtocolClientSideTranslatorPB translator =
      (RefreshUserMappingsProtocolClientSideTranslatorPB)
      NameNodeProxies.createNonHAProxy(conf, nnAddress,
          RefreshUserMappingsProtocol.class,
          UserGroupInformation.getCurrentUser(), true).getProxy();
  assertTrue(
      translator.isMethodSupported("refreshUserToGroupsMappings"));
}