import org.apache.hadoop.ipc.protocolPB.RefreshCallQueueProtocolClientSideTranslatorPB; //导入依赖的package包/类
private static RefreshCallQueueProtocol
    createNNProxyWithRefreshCallQueueProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshCallQueueProtocolPB proxy = (RefreshCallQueueProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshCallQueueProtocolPB.class);
  return new RefreshCallQueueProtocolClientSideTranslatorPB(proxy);
}
 

import org.apache.hadoop.ipc.protocolPB.RefreshCallQueueProtocolClientSideTranslatorPB; //导入依赖的package包/类
@Test
public void testRefreshCallQueueProtocol() throws IOException {
  RefreshCallQueueProtocolClientSideTranslatorPB translator =
      (RefreshCallQueueProtocolClientSideTranslatorPB)
      NameNodeProxies.createNonHAProxy(conf, nnAddress,
          RefreshCallQueueProtocol.class,
          UserGroupInformation.getCurrentUser(), true).getProxy();
  assertTrue(
      translator.isMethodSupported("refreshCallQueue"));
}
 

import org.apache.hadoop.ipc.protocolPB.RefreshCallQueueProtocolClientSideTranslatorPB; //导入依赖的package包/类
private static RefreshCallQueueProtocol
    createNNProxyWithRefreshCallQueueProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshCallQueueProtocolPB proxy = (RefreshCallQueueProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshCallQueueProtocolPB.class, 0);
  return new RefreshCallQueueProtocolClientSideTranslatorPB(proxy);
}