Java 类org.apache.hadoop.mapreduce.v2.api.protocolrecords.impl.pb.KillJobRequestPBImpl 实例源码

@Override
public KillJobResponseProto killJob(RpcController controller,
    KillJobRequestProto proto) throws ServiceException {
  KillJobRequest request = new KillJobRequestPBImpl(proto);
  try {
    KillJobResponse response = real.killJob(request);
    return ((KillJobResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobRequestProto requestProto = ((KillJobRequestPBImpl)request).getProto();
  try {
    return new KillJobResponsePBImpl(proxy.killJob(null, requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}

@Override
public KillJobResponseProto killJob(RpcController controller,
    KillJobRequestProto proto) throws ServiceException {
  KillJobRequest request = new KillJobRequestPBImpl(proto);
  try {
    KillJobResponse response = real.killJob(request);
    return ((KillJobResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobRequestProto requestProto = ((KillJobRequestPBImpl)request).getProto();
  try {
    return new KillJobResponsePBImpl(proxy.killJob(null, requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}

@Override
public KillJobResponseProto killJob(RpcController controller,
    KillJobRequestProto proto) throws ServiceException {
  KillJobRequest request = new KillJobRequestPBImpl(proto);
  try {
    KillJobResponse response = real.killJob(request);
    return ((KillJobResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobRequestProto requestProto = ((KillJobRequestPBImpl)request).getProto();
  try {
    return new KillJobResponsePBImpl(proxy.killJob(null, requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}

@Override
public KillJobResponseProto killJob(RpcController controller,
    KillJobRequestProto proto) throws ServiceException {
  KillJobRequest request = new KillJobRequestPBImpl(proto);
  try {
    KillJobResponse response = real.killJob(request);
    return ((KillJobResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobRequestProto requestProto = ((KillJobRequestPBImpl)request).getProto();
  try {
    return new KillJobResponsePBImpl(proxy.killJob(null, requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}

@Override
public KillJobResponseProto killJob(RpcController controller,
    KillJobRequestProto proto) throws ServiceException {
  KillJobRequest request = new KillJobRequestPBImpl(proto);
  try {
    KillJobResponse response = real.killJob(request);
    return ((KillJobResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobRequestProto requestProto = ((KillJobRequestPBImpl)request).getProto();
  try {
    return new KillJobResponsePBImpl(proxy.killJob(null, requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}

@Override
public KillJobResponseProto killJob(RpcController controller,
    KillJobRequestProto proto) throws ServiceException {
  KillJobRequest request = new KillJobRequestPBImpl(proto);
  try {
    KillJobResponse response = real.killJob(request);
    return ((KillJobResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobRequestProto requestProto = ((KillJobRequestPBImpl)request).getProto();
  try {
    return new KillJobResponsePBImpl(proxy.killJob(null, requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}

@Override
public KillJobResponseProto killJob(RpcController controller,
    KillJobRequestProto proto) throws ServiceException {
  KillJobRequest request = new KillJobRequestPBImpl(proto);
  try {
    KillJobResponse response = real.killJob(request);
    return ((KillJobResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobRequestProto requestProto = ((KillJobRequestPBImpl)request).getProto();
  try {
    return new KillJobResponsePBImpl(proxy.killJob(null, requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}

/**
 * Kill the job, given the jobId
 * @param jobId
 * @return
 * @throws IOException
 */
public boolean killJob(JobId jobId) throws IOException{
    KillJobRequestProto proto = KillJobRequestProto.getDefaultInstance();
    KillJobRequest request = new KillJobRequestPBImpl(proto);
    request.setJobId(jobId);
    KillJobResponse killJobResponse = proxy.killJob(request);
    if(killJobResponse!=null){
        return true;
    }
    return false;
}

@Override
public KillJobResponseProto killJob(RpcController controller,
    KillJobRequestProto proto) throws ServiceException {
  KillJobRequest request = new KillJobRequestPBImpl(proto);
  try {
    KillJobResponse response = real.killJob(request);
    return ((KillJobResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobRequestProto requestProto = ((KillJobRequestPBImpl)request).getProto();
  try {
    return new KillJobResponsePBImpl(proxy.killJob(null, requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}

@Override
public KillJobResponseProto killJob(RpcController controller,
    KillJobRequestProto proto) throws ServiceException {
  KillJobRequest request = new KillJobRequestPBImpl(proto);
  try {
    KillJobResponse response = real.killJob(request);
    return ((KillJobResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobRequestProto requestProto = ((KillJobRequestPBImpl)request).getProto();
  try {
    return new KillJobResponsePBImpl(proxy.killJob(null, requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}

@Override
public KillJobResponseProto killJob(RpcController controller,
    KillJobRequestProto proto) throws ServiceException {
  KillJobRequest request = new KillJobRequestPBImpl(proto);
  try {
    KillJobResponse response = real.killJob(request);
    return ((KillJobResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobRequestProto requestProto = ((KillJobRequestPBImpl)request).getProto();
  try {
    return new KillJobResponsePBImpl(proxy.killJob(null, requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}