Java 类org.apache.hadoop.hdfs.qjournal.protocol.QJournalProtocolProtos.FormatRequestProto 实例源码

public FormatResponseProto format(RpcController controller,
    FormatRequestProto request) throws ServiceException {
  try {
    impl.format(request.getJid().getIdentifier(),
        PBHelper.convert(request.getNsInfo()));
    return FormatResponseProto.getDefaultInstance();
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
}

@Override
public void format(String jid, NamespaceInfo nsInfo) throws IOException {
  try {
    FormatRequestProto req = FormatRequestProto.newBuilder()
        .setJid(convertJournalId(jid))
        .setNsInfo(PBHelper.convert(nsInfo))
        .build();
    rpcProxy.format(NULL_CONTROLLER, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

public FormatResponseProto format(RpcController controller,
    FormatRequestProto request) throws ServiceException {
  try {
    impl.format(request.getJid().getIdentifier(),
        PBHelper.convert(request.getNsInfo()));
    return FormatResponseProto.getDefaultInstance();
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
}

@Override
public void format(String jid, NamespaceInfo nsInfo) throws IOException {
  try {
    FormatRequestProto req = FormatRequestProto.newBuilder()
        .setJid(convertJournalId(jid))
        .setNsInfo(PBHelper.convert(nsInfo))
        .build();
    rpcProxy.format(NULL_CONTROLLER, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

public FormatResponseProto format(RpcController controller,
    FormatRequestProto request) throws ServiceException {
  try {
    impl.format(request.getJid().getIdentifier(),
        PBHelper.convert(request.getNsInfo()));
    return FormatResponseProto.getDefaultInstance();
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
}

@Override
public void format(String jid, NamespaceInfo nsInfo) throws IOException {
  try {
    FormatRequestProto req = FormatRequestProto.newBuilder()
        .setJid(convertJournalId(jid))
        .setNsInfo(PBHelper.convert(nsInfo))
        .build();
    rpcProxy.format(NULL_CONTROLLER, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

public FormatResponseProto format(RpcController controller,
    FormatRequestProto request) throws ServiceException {
  try {
    impl.format(request.getJid().getIdentifier(),
        PBHelper.convert(request.getNsInfo()));
    return FormatResponseProto.getDefaultInstance();
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
}

@Override
public void format(String jid, NamespaceInfo nsInfo) throws IOException {
  try {
    FormatRequestProto req = FormatRequestProto.newBuilder()
        .setJid(convertJournalId(jid))
        .setNsInfo(PBHelper.convert(nsInfo))
        .build();
    rpcProxy.format(NULL_CONTROLLER, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

public FormatResponseProto format(RpcController controller,
    FormatRequestProto request) throws ServiceException {
  try {
    impl.format(request.getJid().getIdentifier(),
        PBHelper.convert(request.getNsInfo()));
    return FormatResponseProto.getDefaultInstance();
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
}

@Override
public void format(String jid, NamespaceInfo nsInfo) throws IOException {
  try {
    FormatRequestProto req = FormatRequestProto.newBuilder()
        .setJid(convertJournalId(jid))
        .setNsInfo(PBHelper.convert(nsInfo))
        .build();
    rpcProxy.format(NULL_CONTROLLER, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

public FormatResponseProto format(RpcController controller,
    FormatRequestProto request) throws ServiceException {
  try {
    impl.format(request.getJid().getIdentifier(),
        PBHelper.convert(request.getNsInfo()));
    return FormatResponseProto.getDefaultInstance();
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
}

@Override
public void format(String jid, NamespaceInfo nsInfo) throws IOException {
  try {
    FormatRequestProto req = FormatRequestProto.newBuilder()
        .setJid(convertJournalId(jid))
        .setNsInfo(PBHelper.convert(nsInfo))
        .build();
    rpcProxy.format(NULL_CONTROLLER, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

public FormatResponseProto format(RpcController controller,
    FormatRequestProto request) throws ServiceException {
  try {
    impl.format(request.getJid().getIdentifier(),
        PBHelper.convert(request.getNsInfo()));
    return FormatResponseProto.getDefaultInstance();
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
}

@Override
public void format(String jid, NamespaceInfo nsInfo) throws IOException {
  try {
    FormatRequestProto req = FormatRequestProto.newBuilder()
        .setJid(convertJournalId(jid))
        .setNsInfo(PBHelper.convert(nsInfo))
        .build();
    rpcProxy.format(NULL_CONTROLLER, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

public FormatResponseProto format(RpcController controller,
    FormatRequestProto request) throws ServiceException {
  try {
    impl.format(request.getJid().getIdentifier(),
        PBHelper.convert(request.getNsInfo()));
    return FormatResponseProto.getDefaultInstance();
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
}

@Override
public void format(String jid, NamespaceInfo nsInfo) throws IOException {
  try {
    FormatRequestProto req = FormatRequestProto.newBuilder()
        .setJid(convertJournalId(jid))
        .setNsInfo(PBHelper.convert(nsInfo))
        .build();
    rpcProxy.format(NULL_CONTROLLER, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}

public FormatResponseProto format(RpcController controller,
    FormatRequestProto request) throws ServiceException {
  try {
    impl.format(request.getJid().getIdentifier(),
        PBHelper.convert(request.getNsInfo()));
    return FormatResponseProto.getDefaultInstance();
  } catch (IOException ioe) {
    throw new ServiceException(ioe);
  }
}

@Override
public void format(String jid, NamespaceInfo nsInfo) throws IOException {
  try {
    FormatRequestProto req = FormatRequestProto.newBuilder()
        .setJid(convertJournalId(jid))
        .setNsInfo(PBHelper.convert(nsInfo))
        .build();
    rpcProxy.format(NULL_CONTROLLER, req);
  } catch (ServiceException e) {
    throw ProtobufHelper.getRemoteException(e);
  }
}