import org.apache.hadoop.ipc.protocolPB.RefreshCallQueueProtocolPB; //导入依赖的package包/类
@Override
public boolean isMethodSupported(String methodName) throws IOException {
  return RpcClientUtil.isMethodSupported(rpcProxy,
      RefreshCallQueueProtocolPB.class,
      RPC.RpcKind.RPC_PROTOCOL_BUFFER,
      RPC.getProtocolVersion(RefreshCallQueueProtocolPB.class),
      methodName);
}
 

import org.apache.hadoop.ipc.protocolPB.RefreshCallQueueProtocolPB; //导入依赖的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.RefreshCallQueueProtocolPB; //导入依赖的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);
}
 

import org.apache.hadoop.ipc.protocolPB.RefreshCallQueueProtocolPB; //导入依赖的package包/类
public RefreshCallQueueProtocolClientSideTranslatorPB(
    RefreshCallQueueProtocolPB rpcProxy) {
  this.rpcProxy = rpcProxy;
}