1. 包列表
  2. 类列表
  3. org.apache.hadoop.mapreduce.v2.api.protocolrecords.KillJobRequest

Java 类org.apache.hadoop.mapreduce.v2.api.protocolrecords.KillJobRequest 实例源码

项目：hadoop    文件：MRClientService.java    
@SuppressWarnings("unchecked")
@Override
public KillJobResponse killJob(KillJobRequest request) 
  throws IOException {
  JobId jobId = request.getJobId();
  UserGroupInformation callerUGI = UserGroupInformation.getCurrentUser();
  String message = "Kill job " + jobId + " received from " + callerUGI
      + " at " + Server.getRemoteAddress();
  LOG.info(message);
  verifyAndGetJob(jobId, JobACL.MODIFY_JOB, false);
  appContext.getEventHandler().handle(
      new JobDiagnosticsUpdateEvent(jobId, message));
  appContext.getEventHandler().handle(
      new JobEvent(jobId, JobEventType.JOB_KILL));
  KillJobResponse response = 
    recordFactory.newRecordInstance(KillJobResponse.class);
  return response;
}
项目：aliyun-oss-hadoop-fs    文件：MRClientService.java    
@SuppressWarnings("unchecked")
@Override
public KillJobResponse killJob(KillJobRequest request) 
  throws IOException {
  JobId jobId = request.getJobId();
  UserGroupInformation callerUGI = UserGroupInformation.getCurrentUser();
  String message = "Kill job " + jobId + " received from " + callerUGI
      + " at " + Server.getRemoteAddress();
  LOG.info(message);
  verifyAndGetJob(jobId, JobACL.MODIFY_JOB, false);
  appContext.getEventHandler().handle(
      new JobDiagnosticsUpdateEvent(jobId, message));
  appContext.getEventHandler().handle(
      new JobEvent(jobId, JobEventType.JOB_KILL));
  KillJobResponse response = 
    recordFactory.newRecordInstance(KillJobResponse.class);
  return response;
}
项目：big-c    文件：MRClientService.java    
@SuppressWarnings("unchecked")
@Override
public KillJobResponse killJob(KillJobRequest request) 
  throws IOException {
  JobId jobId = request.getJobId();
  UserGroupInformation callerUGI = UserGroupInformation.getCurrentUser();
  String message = "Kill job " + jobId + " received from " + callerUGI
      + " at " + Server.getRemoteAddress();
  LOG.info(message);
  verifyAndGetJob(jobId, JobACL.MODIFY_JOB, false);
  appContext.getEventHandler().handle(
      new JobDiagnosticsUpdateEvent(jobId, message));
  appContext.getEventHandler().handle(
      new JobEvent(jobId, JobEventType.JOB_KILL));
  KillJobResponse response = 
    recordFactory.newRecordInstance(KillJobResponse.class);
  return response;
}
项目：hadoop-2.6.0-cdh5.4.3    文件：MRClientService.java    
@SuppressWarnings("unchecked")
@Override
public KillJobResponse killJob(KillJobRequest request) 
  throws IOException {
  JobId jobId = request.getJobId();
  UserGroupInformation callerUGI = UserGroupInformation.getCurrentUser();
  String message = "Kill job " + jobId + " received from " + callerUGI
      + " at " + Server.getRemoteAddress();
  LOG.info(message);
  verifyAndGetJob(jobId, JobACL.MODIFY_JOB);
  appContext.getEventHandler().handle(
      new JobDiagnosticsUpdateEvent(jobId, message));
  appContext.getEventHandler().handle(
      new JobEvent(jobId, JobEventType.JOB_KILL));
  KillJobResponse response = 
    recordFactory.newRecordInstance(KillJobResponse.class);
  return response;
}
项目：hadoop-plus    文件：MRClientService.java    
@SuppressWarnings("unchecked")
@Override
public KillJobResponse killJob(KillJobRequest request) 
  throws IOException {
  JobId jobId = request.getJobId();
  String message = "Kill Job received from client " + jobId;
  LOG.info(message);
 verifyAndGetJob(jobId, true);
  appContext.getEventHandler().handle(
      new JobDiagnosticsUpdateEvent(jobId, message));
  appContext.getEventHandler().handle(
      new JobEvent(jobId, JobEventType.JOB_KILL));
  KillJobResponse response = 
    recordFactory.newRecordInstance(KillJobResponse.class);
  return response;
}
项目：FlexMap    文件：MRClientService.java    
@SuppressWarnings("unchecked")
@Override
public KillJobResponse killJob(KillJobRequest request) 
  throws IOException {
  JobId jobId = request.getJobId();
  UserGroupInformation callerUGI = UserGroupInformation.getCurrentUser();
  String message = "Kill job " + jobId + " received from " + callerUGI
      + " at " + Server.getRemoteAddress();
  LOG.info(message);
  verifyAndGetJob(jobId, JobACL.MODIFY_JOB);
  appContext.getEventHandler().handle(
      new JobDiagnosticsUpdateEvent(jobId, message));
  appContext.getEventHandler().handle(
      new JobEvent(jobId, JobEventType.JOB_KILL));
  KillJobResponse response = 
    recordFactory.newRecordInstance(KillJobResponse.class);
  return response;
}
项目：hops    文件：MRClientService.java    
@SuppressWarnings("unchecked")
@Override
public KillJobResponse killJob(KillJobRequest request) 
  throws IOException {
  JobId jobId = request.getJobId();
  UserGroupInformation callerUGI = UserGroupInformation.getCurrentUser();
  String message = "Kill job " + jobId + " received from " + callerUGI
      + " at " + Server.getRemoteAddress();
  LOG.info(message);
  verifyAndGetJob(jobId, JobACL.MODIFY_JOB, false);
  appContext.getEventHandler().handle(
      new JobDiagnosticsUpdateEvent(jobId, message));
  appContext.getEventHandler().handle(
      new JobEvent(jobId, JobEventType.JOB_KILL));
  KillJobResponse response = 
    recordFactory.newRecordInstance(KillJobResponse.class);
  return response;
}
项目：hadoop-TCP    文件：MRClientService.java    
@SuppressWarnings("unchecked")
@Override
public KillJobResponse killJob(KillJobRequest request) 
  throws IOException {
  JobId jobId = request.getJobId();
  UserGroupInformation callerUGI = UserGroupInformation.getCurrentUser();
  String message = "Kill job " + jobId + " received from " + callerUGI
      + " at " + Server.getRemoteAddress();
  LOG.info(message);
  verifyAndGetJob(jobId, JobACL.MODIFY_JOB);
  appContext.getEventHandler().handle(
      new JobDiagnosticsUpdateEvent(jobId, message));
  appContext.getEventHandler().handle(
      new JobEvent(jobId, JobEventType.JOB_KILL));
  KillJobResponse response = 
    recordFactory.newRecordInstance(KillJobResponse.class);
  return response;
}
项目：hardfs    文件：MRClientService.java    
@SuppressWarnings("unchecked")
@Override
public KillJobResponse killJob(KillJobRequest request) 
  throws IOException {
  JobId jobId = request.getJobId();
  UserGroupInformation callerUGI = UserGroupInformation.getCurrentUser();
  String message = "Kill job " + jobId + " received from " + callerUGI
      + " at " + Server.getRemoteAddress();
  LOG.info(message);
  verifyAndGetJob(jobId, JobACL.MODIFY_JOB);
  appContext.getEventHandler().handle(
      new JobDiagnosticsUpdateEvent(jobId, message));
  appContext.getEventHandler().handle(
      new JobEvent(jobId, JobEventType.JOB_KILL));
  KillJobResponse response = 
    recordFactory.newRecordInstance(KillJobResponse.class);
  return response;
}
项目：hadoop-on-lustre2    文件：MRClientService.java    
@SuppressWarnings("unchecked")
@Override
public KillJobResponse killJob(KillJobRequest request) 
  throws IOException {
  JobId jobId = request.getJobId();
  UserGroupInformation callerUGI = UserGroupInformation.getCurrentUser();
  String message = "Kill job " + jobId + " received from " + callerUGI
      + " at " + Server.getRemoteAddress();
  LOG.info(message);
  verifyAndGetJob(jobId, JobACL.MODIFY_JOB);
  appContext.getEventHandler().handle(
      new JobDiagnosticsUpdateEvent(jobId, message));
  appContext.getEventHandler().handle(
      new JobEvent(jobId, JobEventType.JOB_KILL));
  KillJobResponse response = 
    recordFactory.newRecordInstance(KillJobResponse.class);
  return response;
}
项目：hadoop    文件：NotRunningJob.java    
@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobResponse resp =
    recordFactory.newRecordInstance(KillJobResponse.class);
  return resp;
}
项目：hadoop    文件：ClientServiceDelegate.java    
public boolean killJob(JobID oldJobID)
     throws IOException {
  org.apache.hadoop.mapreduce.v2.api.records.JobId jobId
  = TypeConverter.toYarn(oldJobID);
  KillJobRequest killRequest = recordFactory.newRecordInstance(KillJobRequest.class);
  killRequest.setJobId(jobId);
  invoke("killJob", KillJobRequest.class, killRequest);
  return true;
}
项目：hadoop    文件：MRClientProtocolPBServiceImpl.java    
@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);
  }
}
项目：hadoop    文件：MRClientProtocolPBClientImpl.java    
@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);
  }
}
项目：aliyun-oss-hadoop-fs    文件：NotRunningJob.java    
@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobResponse resp =
    recordFactory.newRecordInstance(KillJobResponse.class);
  return resp;
}
项目：aliyun-oss-hadoop-fs    文件：ClientServiceDelegate.java    
public boolean killJob(JobID oldJobID)
     throws IOException {
  org.apache.hadoop.mapreduce.v2.api.records.JobId jobId
  = TypeConverter.toYarn(oldJobID);
  KillJobRequest killRequest = recordFactory.newRecordInstance(KillJobRequest.class);
  killRequest.setJobId(jobId);
  invoke("killJob", KillJobRequest.class, killRequest);
  return true;
}
项目：aliyun-oss-hadoop-fs    文件：MRClientProtocolPBServiceImpl.java    
@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);
  }
}
项目：aliyun-oss-hadoop-fs    文件：MRClientProtocolPBClientImpl.java    
@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);
  }
}
项目：big-c    文件：NotRunningJob.java    
@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobResponse resp =
    recordFactory.newRecordInstance(KillJobResponse.class);
  return resp;
}
项目：big-c    文件：ClientServiceDelegate.java    
public boolean killJob(JobID oldJobID)
     throws IOException {
  org.apache.hadoop.mapreduce.v2.api.records.JobId jobId
  = TypeConverter.toYarn(oldJobID);
  KillJobRequest killRequest = recordFactory.newRecordInstance(KillJobRequest.class);
  killRequest.setJobId(jobId);
  invoke("killJob", KillJobRequest.class, killRequest);
  return true;
}
项目：big-c    文件：MRClientProtocolPBServiceImpl.java    
@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);
  }
}
项目：big-c    文件：MRClientProtocolPBClientImpl.java    
@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);
  }
}
项目：hadoop-2.6.0-cdh5.4.3    文件：NotRunningJob.java    
@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobResponse resp =
    recordFactory.newRecordInstance(KillJobResponse.class);
  return resp;
}
项目：hadoop-2.6.0-cdh5.4.3    文件：ClientServiceDelegate.java    
public boolean killJob(JobID oldJobID)
     throws IOException {
  org.apache.hadoop.mapreduce.v2.api.records.JobId jobId
  = TypeConverter.toYarn(oldJobID);
  KillJobRequest killRequest = recordFactory.newRecordInstance(KillJobRequest.class);
  killRequest.setJobId(jobId);
  invoke("killJob", KillJobRequest.class, killRequest);
  return true;
}
项目：hadoop-2.6.0-cdh5.4.3    文件：MRClientProtocolPBServiceImpl.java    
@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);
  }
}
项目：hadoop-2.6.0-cdh5.4.3    文件：MRClientProtocolPBClientImpl.java    
@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);
  }
}
项目：hadoop-plus    文件：NotRunningJob.java    
@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobResponse resp =
    recordFactory.newRecordInstance(KillJobResponse.class);
  return resp;
}
项目：hadoop-plus    文件：ClientServiceDelegate.java    
public boolean killJob(JobID oldJobID)
     throws IOException {
  org.apache.hadoop.mapreduce.v2.api.records.JobId jobId
  = TypeConverter.toYarn(oldJobID);
  KillJobRequest killRequest = recordFactory.newRecordInstance(KillJobRequest.class);
  killRequest.setJobId(jobId);
  invoke("killJob", KillJobRequest.class, killRequest);
  return true;
}
项目：hadoop-plus    文件：MRClientProtocolPBServiceImpl.java    
@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);
  }
}
项目：hadoop-plus    文件：MRClientProtocolPBClientImpl.java    
@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);
  }
}
项目：FlexMap    文件：NotRunningJob.java    
@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobResponse resp =
    recordFactory.newRecordInstance(KillJobResponse.class);
  return resp;
}
项目：FlexMap    文件：ClientServiceDelegate.java    
public boolean killJob(JobID oldJobID)
     throws IOException {
  org.apache.hadoop.mapreduce.v2.api.records.JobId jobId
  = TypeConverter.toYarn(oldJobID);
  KillJobRequest killRequest = recordFactory.newRecordInstance(KillJobRequest.class);
  killRequest.setJobId(jobId);
  invoke("killJob", KillJobRequest.class, killRequest);
  return true;
}
项目：FlexMap    文件：MRClientProtocolPBServiceImpl.java    
@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);
  }
}
项目：FlexMap    文件：MRClientProtocolPBClientImpl.java    
@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);
  }
}
项目：hops    文件：NotRunningJob.java    
@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobResponse resp =
    recordFactory.newRecordInstance(KillJobResponse.class);
  return resp;
}
项目：hops    文件：ClientServiceDelegate.java    
public boolean killJob(JobID oldJobID)
     throws IOException {
  org.apache.hadoop.mapreduce.v2.api.records.JobId jobId
  = TypeConverter.toYarn(oldJobID);
  KillJobRequest killRequest = recordFactory.newRecordInstance(KillJobRequest.class);
  killRequest.setJobId(jobId);
  invoke("killJob", KillJobRequest.class, killRequest);
  return true;
}
项目：hops    文件：MRClientProtocolPBServiceImpl.java    
@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);
  }
}
项目：hops    文件：MRClientProtocolPBClientImpl.java    
@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);
  }
}
项目：jumbune    文件：MRCommunicator.java    
/**
 * 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;
}
项目：hadoop-TCP    文件：NotRunningJob.java    
@Override
public KillJobResponse killJob(KillJobRequest request)
    throws IOException {
  KillJobResponse resp =
    recordFactory.newRecordInstance(KillJobResponse.class);
  return resp;
}