Java 类org.apache.hadoop.hdfs.protocol.proto.ClientDatanodeProtocolProtos.GetBlockLocalPathInfoRequestProto 实例源码

项目：hadoop 文件：ClientDatanodeProtocolTranslatorPB.java

@Override
public BlockLocalPathInfo getBlockLocalPathInfo(ExtendedBlock block,
    Token<BlockTokenIdentifier> token) throws IOException {
  GetBlockLocalPathInfoRequestProto req =
      GetBlockLocalPathInfoRequestProto.newBuilder()
      .setBlock(PBHelper.convert(block))
      .setToken(PBHelper.convert(token)).build();
  GetBlockLocalPathInfoResponseProto resp;
  try {
    resp = rpcProxy.getBlockLocalPathInfo(NULL_CONTROLLER, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
  return new BlockLocalPathInfo(PBHelper.convert(resp.getBlock()),
      resp.getLocalPath(), resp.getLocalMetaPath());
}

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

@Override
public BlockLocalPathInfo getBlockLocalPathInfo(ExtendedBlock block,
    Token<BlockTokenIdentifier> token) throws IOException {
  GetBlockLocalPathInfoRequestProto req =
      GetBlockLocalPathInfoRequestProto.newBuilder()
          .setBlock(PBHelperClient.convert(block))
          .setToken(PBHelperClient.convert(token)).build();
  GetBlockLocalPathInfoResponseProto resp;
  try {
    resp = rpcProxy.getBlockLocalPathInfo(NULL_CONTROLLER, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
  return new BlockLocalPathInfo(PBHelperClient.convert(resp.getBlock()),
      resp.getLocalPath(), resp.getLocalMetaPath());
}

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

@Override
public GetBlockLocalPathInfoResponseProto getBlockLocalPathInfo(
    RpcController unused, GetBlockLocalPathInfoRequestProto request)
    throws ServiceException {
  BlockLocalPathInfo resp;
  try {
    resp = impl.getBlockLocalPathInfo(
               PBHelperClient.convert(request.getBlock()),
               PBHelperClient.convert(request.getToken()));
  } catch (IOException e) {
    throw new ServiceException(e);
  }
  return GetBlockLocalPathInfoResponseProto.newBuilder()
      .setBlock(PBHelperClient.convert(resp.getBlock()))
      .setLocalPath(resp.getBlockPath()).setLocalMetaPath(resp.getMetaPath())
      .build();
}

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

@Override
public BlockLocalPathInfo getBlockLocalPathInfo(ExtendedBlock block,
    Token<BlockTokenIdentifier> token) throws IOException {
  GetBlockLocalPathInfoRequestProto req =
      GetBlockLocalPathInfoRequestProto.newBuilder()
      .setBlock(PBHelper.convert(block))
      .setToken(PBHelper.convert(token)).build();
  GetBlockLocalPathInfoResponseProto resp;
  try {
    resp = rpcProxy.getBlockLocalPathInfo(NULL_CONTROLLER, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
  return new BlockLocalPathInfo(PBHelper.convert(resp.getBlock()),
      resp.getLocalPath(), resp.getLocalMetaPath());
}

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

@Override
public BlockLocalPathInfo getBlockLocalPathInfo(ExtendedBlock block,
    Token<BlockTokenIdentifier> token) throws IOException {
  GetBlockLocalPathInfoRequestProto req =
      GetBlockLocalPathInfoRequestProto.newBuilder()
      .setBlock(PBHelper.convert(block))
      .setToken(PBHelper.convert(token)).build();
  GetBlockLocalPathInfoResponseProto resp;
  try {
    resp = rpcProxy.getBlockLocalPathInfo(NULL_CONTROLLER, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
  return new BlockLocalPathInfo(PBHelper.convert(resp.getBlock()),
      resp.getLocalPath(), resp.getLocalMetaPath());
}

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

@Override
public BlockLocalPathInfo getBlockLocalPathInfo(ExtendedBlock block,
    Token<BlockTokenIdentifier> token) throws IOException {
  GetBlockLocalPathInfoRequestProto req =
      GetBlockLocalPathInfoRequestProto.newBuilder()
      .setBlock(PBHelper.convert(block))
      .setToken(PBHelper.convert(token)).build();
  GetBlockLocalPathInfoResponseProto resp;
  try {
    resp = rpcProxy.getBlockLocalPathInfo(NULL_CONTROLLER, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
  return new BlockLocalPathInfo(PBHelper.convert(resp.getBlock()),
      resp.getLocalPath(), resp.getLocalMetaPath());
}

项目：FlexMap 文件：ClientDatanodeProtocolTranslatorPB.java

@Override
public BlockLocalPathInfo getBlockLocalPathInfo(ExtendedBlock block,
    Token<BlockTokenIdentifier> token) throws IOException {
  GetBlockLocalPathInfoRequestProto req =
      GetBlockLocalPathInfoRequestProto.newBuilder()
      .setBlock(PBHelper.convert(block))
      .setToken(PBHelper.convert(token)).build();
  GetBlockLocalPathInfoResponseProto resp;
  try {
    resp = rpcProxy.getBlockLocalPathInfo(NULL_CONTROLLER, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
  return new BlockLocalPathInfo(PBHelper.convert(resp.getBlock()),
      resp.getLocalPath(), resp.getLocalMetaPath());
}

项目：hops 文件：ClientDatanodeProtocolTranslatorPB.java

@Override
public BlockLocalPathInfo getBlockLocalPathInfo(ExtendedBlock block,
    Token<BlockTokenIdentifier> token) throws IOException {
  GetBlockLocalPathInfoRequestProto req =
      GetBlockLocalPathInfoRequestProto.newBuilder()
          .setBlock(PBHelper.convert(block)).setToken(PBHelper.convert(token))
          .build();
  GetBlockLocalPathInfoResponseProto resp;
  try {
    resp = rpcProxy.getBlockLocalPathInfo(NULL_CONTROLLER, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
  return new BlockLocalPathInfo(PBHelper.convert(resp.getBlock()),
      resp.getLocalPath(), resp.getLocalMetaPath());
}

项目：hops 文件：ClientDatanodeProtocolServerSideTranslatorPB.java

@Override
public GetBlockLocalPathInfoResponseProto getBlockLocalPathInfo(
    RpcController unused, GetBlockLocalPathInfoRequestProto request)
    throws ServiceException {
  BlockLocalPathInfo resp;
  try {
    resp = impl.getBlockLocalPathInfo(PBHelper.convert(request.getBlock()),
        PBHelper.convert(request.getToken()));
  } catch (IOException e) {
    throw new ServiceException(e);
  }
  return GetBlockLocalPathInfoResponseProto.newBuilder()
      .setBlock(PBHelper.convert(resp.getBlock()))
      .setLocalPath(resp.getBlockPath()).setLocalMetaPath(resp.getMetaPath())
      .build();
}

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

@Override
public BlockLocalPathInfo getBlockLocalPathInfo(ExtendedBlock block,
    Token<BlockTokenIdentifier> token) throws IOException {
  GetBlockLocalPathInfoRequestProto req =
      GetBlockLocalPathInfoRequestProto.newBuilder()
      .setBlock(PBHelper.convert(block))
      .setToken(PBHelper.convert(token)).build();
  GetBlockLocalPathInfoResponseProto resp;
  try {
    resp = rpcProxy.getBlockLocalPathInfo(NULL_CONTROLLER, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
  return new BlockLocalPathInfo(PBHelper.convert(resp.getBlock()),
      resp.getLocalPath(), resp.getLocalMetaPath());
}

项目：hardfs 文件：ClientDatanodeProtocolTranslatorPB.java

@Override
public BlockLocalPathInfo getBlockLocalPathInfo(ExtendedBlock block,
    Token<BlockTokenIdentifier> token) throws IOException {
  GetBlockLocalPathInfoRequestProto req =
      GetBlockLocalPathInfoRequestProto.newBuilder()
      .setBlock(PBHelper.convert(block))
      .setToken(PBHelper.convert(token)).build();
  GetBlockLocalPathInfoResponseProto resp;
  try {
    resp = rpcProxy.getBlockLocalPathInfo(NULL_CONTROLLER, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
  return new BlockLocalPathInfo(PBHelper.convert(resp.getBlock()),
      resp.getLocalPath(), resp.getLocalMetaPath());
}

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

@Override
public BlockLocalPathInfo getBlockLocalPathInfo(ExtendedBlock block,
    Token<BlockTokenIdentifier> token) throws IOException {
  GetBlockLocalPathInfoRequestProto req =
      GetBlockLocalPathInfoRequestProto.newBuilder()
      .setBlock(PBHelper.convert(block))
      .setToken(PBHelper.convert(token)).build();
  GetBlockLocalPathInfoResponseProto resp;
  try {
    resp = rpcProxy.getBlockLocalPathInfo(NULL_CONTROLLER, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
  return new BlockLocalPathInfo(PBHelper.convert(resp.getBlock()),
      resp.getLocalPath(), resp.getLocalMetaPath());
}

项目：hadoop 文件：ClientDatanodeProtocolServerSideTranslatorPB.java

@Override
public GetBlockLocalPathInfoResponseProto getBlockLocalPathInfo(
    RpcController unused, GetBlockLocalPathInfoRequestProto request)
    throws ServiceException {
  BlockLocalPathInfo resp;
  try {
    resp = impl.getBlockLocalPathInfo(PBHelper.convert(request.getBlock()), PBHelper.convert(request.getToken()));
  } catch (IOException e) {
    throw new ServiceException(e);
  }
  return GetBlockLocalPathInfoResponseProto.newBuilder()
      .setBlock(PBHelper.convert(resp.getBlock()))
      .setLocalPath(resp.getBlockPath()).setLocalMetaPath(resp.getMetaPath())
      .build();
}

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

@Override
public GetBlockLocalPathInfoResponseProto getBlockLocalPathInfo(
    RpcController unused, GetBlockLocalPathInfoRequestProto request)
    throws ServiceException {
  BlockLocalPathInfo resp;
  try {
    resp = impl.getBlockLocalPathInfo(PBHelper.convert(request.getBlock()), PBHelper.convert(request.getToken()));
  } catch (IOException e) {
    throw new ServiceException(e);
  }
  return GetBlockLocalPathInfoResponseProto.newBuilder()
      .setBlock(PBHelper.convert(resp.getBlock()))
      .setLocalPath(resp.getBlockPath()).setLocalMetaPath(resp.getMetaPath())
      .build();
}

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

@Override
public GetBlockLocalPathInfoResponseProto getBlockLocalPathInfo(
    RpcController unused, GetBlockLocalPathInfoRequestProto request)
    throws ServiceException {
  BlockLocalPathInfo resp;
  try {
    resp = impl.getBlockLocalPathInfo(PBHelper.convert(request.getBlock()), PBHelper.convert(request.getToken()));
  } catch (IOException e) {
    throw new ServiceException(e);
  }
  return GetBlockLocalPathInfoResponseProto.newBuilder()
      .setBlock(PBHelper.convert(resp.getBlock()))
      .setLocalPath(resp.getBlockPath()).setLocalMetaPath(resp.getMetaPath())
      .build();
}

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

@Override
public GetBlockLocalPathInfoResponseProto getBlockLocalPathInfo(
    RpcController unused, GetBlockLocalPathInfoRequestProto request)
    throws ServiceException {
  BlockLocalPathInfo resp;
  try {
    resp = impl.getBlockLocalPathInfo(PBHelper.convert(request.getBlock()), PBHelper.convert(request.getToken()));
  } catch (IOException e) {
    throw new ServiceException(e);
  }
  return GetBlockLocalPathInfoResponseProto.newBuilder()
      .setBlock(PBHelper.convert(resp.getBlock()))
      .setLocalPath(resp.getBlockPath()).setLocalMetaPath(resp.getMetaPath())
      .build();
}

项目：FlexMap 文件：ClientDatanodeProtocolServerSideTranslatorPB.java

@Override
public GetBlockLocalPathInfoResponseProto getBlockLocalPathInfo(
    RpcController unused, GetBlockLocalPathInfoRequestProto request)
    throws ServiceException {
  BlockLocalPathInfo resp;
  try {
    resp = impl.getBlockLocalPathInfo(PBHelper.convert(request.getBlock()), PBHelper.convert(request.getToken()));
  } catch (IOException e) {
    throw new ServiceException(e);
  }
  return GetBlockLocalPathInfoResponseProto.newBuilder()
      .setBlock(PBHelper.convert(resp.getBlock()))
      .setLocalPath(resp.getBlockPath()).setLocalMetaPath(resp.getMetaPath())
      .build();
}

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

@Override
public GetBlockLocalPathInfoResponseProto getBlockLocalPathInfo(
    RpcController unused, GetBlockLocalPathInfoRequestProto request)
    throws ServiceException {
  BlockLocalPathInfo resp;
  try {
    resp = impl.getBlockLocalPathInfo(PBHelper.convert(request.getBlock()), PBHelper.convert(request.getToken()));
  } catch (IOException e) {
    throw new ServiceException(e);
  }
  return GetBlockLocalPathInfoResponseProto.newBuilder()
      .setBlock(PBHelper.convert(resp.getBlock()))
      .setLocalPath(resp.getBlockPath()).setLocalMetaPath(resp.getMetaPath())
      .build();
}

项目：hardfs 文件：ClientDatanodeProtocolServerSideTranslatorPB.java

@Override
public GetBlockLocalPathInfoResponseProto getBlockLocalPathInfo(
    RpcController unused, GetBlockLocalPathInfoRequestProto request)
    throws ServiceException {
  BlockLocalPathInfo resp;
  try {
    resp = impl.getBlockLocalPathInfo(PBHelper.convert(request.getBlock()), PBHelper.convert(request.getToken()));
  } catch (IOException e) {
    throw new ServiceException(e);
  }
  return GetBlockLocalPathInfoResponseProto.newBuilder()
      .setBlock(PBHelper.convert(resp.getBlock()))
      .setLocalPath(resp.getBlockPath()).setLocalMetaPath(resp.getMetaPath())
      .build();
}

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

@Override
public GetBlockLocalPathInfoResponseProto getBlockLocalPathInfo(
    RpcController unused, GetBlockLocalPathInfoRequestProto request)
    throws ServiceException {
  BlockLocalPathInfo resp;
  try {
    resp = impl.getBlockLocalPathInfo(PBHelper.convert(request.getBlock()), PBHelper.convert(request.getToken()));
  } catch (IOException e) {
    throw new ServiceException(e);
  }
  return GetBlockLocalPathInfoResponseProto.newBuilder()
      .setBlock(PBHelper.convert(resp.getBlock()))
      .setLocalPath(resp.getBlockPath()).setLocalMetaPath(resp.getMetaPath())
      .build();
}