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

@Override
public boolean isMethodSupported(String methodName) throws IOException {
  return RpcClientUtil.isMethodSupported(rpcProxy,
      RefreshAuthorizationPolicyProtocolPB.class,
      RPC.RpcKind.RPC_PROTOCOL_BUFFER,
      RPC.getProtocolVersion(RefreshAuthorizationPolicyProtocolPB.class),
      methodName);
}

private static RefreshAuthorizationPolicyProtocol
    createNNProxyWithRefreshAuthorizationPolicyProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshAuthorizationPolicyProtocolPB proxy = (RefreshAuthorizationPolicyProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshAuthorizationPolicyProtocolPB.class);
  return new RefreshAuthorizationPolicyProtocolClientSideTranslatorPB(proxy);
}

@Override
public boolean isMethodSupported(String methodName) throws IOException {
  return RpcClientUtil.isMethodSupported(rpcProxy,
      RefreshAuthorizationPolicyProtocolPB.class,
      RPC.RpcKind.RPC_PROTOCOL_BUFFER,
      RPC.getProtocolVersion(RefreshAuthorizationPolicyProtocolPB.class),
      methodName);
}

private static RefreshAuthorizationPolicyProtocol
    createNNProxyWithRefreshAuthorizationPolicyProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshAuthorizationPolicyProtocolPB proxy = (RefreshAuthorizationPolicyProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshAuthorizationPolicyProtocolPB.class, 0);
  return new RefreshAuthorizationPolicyProtocolClientSideTranslatorPB(proxy);
}

@Override
public boolean isMethodSupported(String methodName) throws IOException {
  return RpcClientUtil.isMethodSupported(rpcProxy,
      RefreshAuthorizationPolicyProtocolPB.class,
      RPC.RpcKind.RPC_PROTOCOL_BUFFER,
      RPC.getProtocolVersion(RefreshAuthorizationPolicyProtocolPB.class),
      methodName);
}

private static RefreshAuthorizationPolicyProtocol
    createNNProxyWithRefreshAuthorizationPolicyProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshAuthorizationPolicyProtocolPB proxy = (RefreshAuthorizationPolicyProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshAuthorizationPolicyProtocolPB.class);
  return new RefreshAuthorizationPolicyProtocolClientSideTranslatorPB(proxy);
}

@Override
public boolean isMethodSupported(String methodName) throws IOException {
  return RpcClientUtil.isMethodSupported(rpcProxy,
      RefreshAuthorizationPolicyProtocolPB.class,
      RPC.RpcKind.RPC_PROTOCOL_BUFFER,
      RPC.getProtocolVersion(RefreshAuthorizationPolicyProtocolPB.class),
      methodName);
}

private static RefreshAuthorizationPolicyProtocol
    createNNProxyWithRefreshAuthorizationPolicyProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshAuthorizationPolicyProtocolPB proxy = (RefreshAuthorizationPolicyProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshAuthorizationPolicyProtocolPB.class);
  return new RefreshAuthorizationPolicyProtocolClientSideTranslatorPB(proxy);
}

@Override
public boolean isMethodSupported(String methodName) throws IOException {
  return RpcClientUtil.isMethodSupported(rpcProxy,
      RefreshAuthorizationPolicyProtocolPB.class,
      RPC.RpcKind.RPC_PROTOCOL_BUFFER,
      RPC.getProtocolVersion(RefreshAuthorizationPolicyProtocolPB.class),
      methodName);
}

private static RefreshAuthorizationPolicyProtocol
    createNNProxyWithRefreshAuthorizationPolicyProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshAuthorizationPolicyProtocolPB proxy = (RefreshAuthorizationPolicyProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshAuthorizationPolicyProtocolPB.class);
  return new RefreshAuthorizationPolicyProtocolClientSideTranslatorPB(proxy);
}

@Override
public boolean isMethodSupported(String methodName) throws IOException {
  return RpcClientUtil.isMethodSupported(rpcProxy,
      RefreshAuthorizationPolicyProtocolPB.class,
      RPC.RpcKind.RPC_PROTOCOL_BUFFER,
      RPC.getProtocolVersion(RefreshAuthorizationPolicyProtocolPB.class),
      methodName);
}

private static RefreshAuthorizationPolicyProtocol
    createNNProxyWithRefreshAuthorizationPolicyProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshAuthorizationPolicyProtocolPB proxy = (RefreshAuthorizationPolicyProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshAuthorizationPolicyProtocolPB.class);
  return new RefreshAuthorizationPolicyProtocolClientSideTranslatorPB(proxy);
}

private static RefreshAuthorizationPolicyProtocol createNNProxyWithRefreshAuthorizationPolicyProtocol(
    InetSocketAddress address, Configuration conf, UserGroupInformation ugi)
    throws IOException {
  RefreshAuthorizationPolicyProtocolPB proxy =
      (RefreshAuthorizationPolicyProtocolPB) createNameNodeProxy(address,
          conf, ugi, RefreshAuthorizationPolicyProtocolPB.class);
  return new RefreshAuthorizationPolicyProtocolClientSideTranslatorPB(proxy);
}

@Override
public boolean isMethodSupported(String methodName) throws IOException {
  return RpcClientUtil.isMethodSupported(rpcProxy,
      RefreshAuthorizationPolicyProtocolPB.class,
      RPC.RpcKind.RPC_PROTOCOL_BUFFER,
      RPC.getProtocolVersion(RefreshAuthorizationPolicyProtocolPB.class),
      methodName);
}

private static RefreshAuthorizationPolicyProtocol
    createNNProxyWithRefreshAuthorizationPolicyProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshAuthorizationPolicyProtocolPB proxy = (RefreshAuthorizationPolicyProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshAuthorizationPolicyProtocolPB.class);
  return new RefreshAuthorizationPolicyProtocolClientSideTranslatorPB(proxy);
}

@Override
public boolean isMethodSupported(String methodName) throws IOException {
  return RpcClientUtil.isMethodSupported(rpcProxy,
      RefreshAuthorizationPolicyProtocolPB.class,
      RPC.RpcKind.RPC_PROTOCOL_BUFFER,
      RPC.getProtocolVersion(RefreshAuthorizationPolicyProtocolPB.class),
      methodName);
}

private static RefreshAuthorizationPolicyProtocol
    createNNProxyWithRefreshAuthorizationPolicyProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshAuthorizationPolicyProtocolPB proxy = (RefreshAuthorizationPolicyProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshAuthorizationPolicyProtocolPB.class);
  return new RefreshAuthorizationPolicyProtocolClientSideTranslatorPB(proxy);
}

@Override
public boolean isMethodSupported(String methodName) throws IOException {
  return RpcClientUtil.isMethodSupported(rpcProxy,
      RefreshAuthorizationPolicyProtocolPB.class,
      RPC.RpcKind.RPC_PROTOCOL_BUFFER,
      RPC.getProtocolVersion(RefreshAuthorizationPolicyProtocolPB.class),
      methodName);
}

private static RefreshAuthorizationPolicyProtocol
    createNNProxyWithRefreshAuthorizationPolicyProtocol(InetSocketAddress address,
        Configuration conf, UserGroupInformation ugi) throws IOException {
  RefreshAuthorizationPolicyProtocolPB proxy = (RefreshAuthorizationPolicyProtocolPB)
      createNameNodeProxy(address, conf, ugi, RefreshAuthorizationPolicyProtocolPB.class);
  return new RefreshAuthorizationPolicyProtocolClientSideTranslatorPB(proxy);
}

@Override
public boolean isMethodSupported(String methodName) throws IOException {
  return RpcClientUtil.isMethodSupported(rpcProxy,
      RefreshAuthorizationPolicyProtocolPB.class,
      RPC.RpcKind.RPC_PROTOCOL_BUFFER,
      RPC.getProtocolVersion(RefreshAuthorizationPolicyProtocolPB.class),
      methodName);
}

public RefreshAuthorizationPolicyProtocolClientSideTranslatorPB(
    RefreshAuthorizationPolicyProtocolPB rpcProxy) {
  this.rpcProxy = rpcProxy;
}

public RefreshAuthorizationPolicyProtocolClientSideTranslatorPB(
    RefreshAuthorizationPolicyProtocolPB rpcProxy) {
  this.rpcProxy = rpcProxy;
}

public RefreshAuthorizationPolicyProtocolClientSideTranslatorPB(
    RefreshAuthorizationPolicyProtocolPB rpcProxy) {
  this.rpcProxy = rpcProxy;
}

public RefreshAuthorizationPolicyProtocolClientSideTranslatorPB(
    RefreshAuthorizationPolicyProtocolPB rpcProxy) {
  this.rpcProxy = rpcProxy;
}

public RefreshAuthorizationPolicyProtocolClientSideTranslatorPB(
    RefreshAuthorizationPolicyProtocolPB rpcProxy) {
  this.rpcProxy = rpcProxy;
}

public RefreshAuthorizationPolicyProtocolClientSideTranslatorPB(
    RefreshAuthorizationPolicyProtocolPB rpcProxy) {
  this.rpcProxy = rpcProxy;
}

public RefreshAuthorizationPolicyProtocolClientSideTranslatorPB(
    RefreshAuthorizationPolicyProtocolPB rpcProxy) {
  this.rpcProxy = rpcProxy;
}

public RefreshAuthorizationPolicyProtocolClientSideTranslatorPB(
    RefreshAuthorizationPolicyProtocolPB rpcProxy) {
  this.rpcProxy = rpcProxy;
}

public RefreshAuthorizationPolicyProtocolClientSideTranslatorPB(
    RefreshAuthorizationPolicyProtocolPB rpcProxy) {
  this.rpcProxy = rpcProxy;
}

public RefreshAuthorizationPolicyProtocolClientSideTranslatorPB(
    RefreshAuthorizationPolicyProtocolPB rpcProxy) {
  this.rpcProxy = rpcProxy;
}