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

项目：hadoop 文件：ClientServiceDelegate.java

public org.apache.hadoop.mapreduce.Counters getJobCounters(JobID arg0) throws IOException,
InterruptedException {
  org.apache.hadoop.mapreduce.v2.api.records.JobId jobID = TypeConverter.toYarn(arg0);
    GetCountersRequest request = recordFactory.newRecordInstance(GetCountersRequest.class);
    request.setJobId(jobID);
    Counters cnt = ((GetCountersResponse)
        invoke("getCounters", GetCountersRequest.class, request)).getCounters();
    return TypeConverter.fromYarn(cnt);

}

项目：hadoop 文件：MRClientService.java

@Override
public GetCountersResponse getCounters(GetCountersRequest request) 
  throws IOException {
  JobId jobId = request.getJobId();
  Job job = verifyAndGetJob(jobId, JobACL.VIEW_JOB, true);
  GetCountersResponse response =
    recordFactory.newRecordInstance(GetCountersResponse.class);
  response.setCounters(TypeConverter.toYarn(job.getAllCounters()));
  return response;
}

项目：hadoop 文件：NotRunningJob.java

@Override
public GetCountersResponse getCounters(GetCountersRequest request)
    throws IOException {
  GetCountersResponse resp =
    recordFactory.newRecordInstance(GetCountersResponse.class);
  Counters counters = recordFactory.newRecordInstance(Counters.class);
  counters.addAllCounterGroups(new HashMap<String, CounterGroup>());
  resp.setCounters(counters);
  return resp;
}

项目：hadoop 文件：TestClientRedirect.java

@Override
 public GetCountersResponse getCounters(GetCountersRequest request)
     throws IOException {
   hsContact = true;
   Counters counters = getMyCounters();
   GetCountersResponse response = recordFactory.newRecordInstance(GetCountersResponse.class);
   response.setCounters(counters);
   return response;
}

项目：hadoop 文件：TestClientRedirect.java

@Override
public GetCountersResponse getCounters(GetCountersRequest request)
    throws IOException {
  JobId jobID = request.getJobId();

  amContact = true;

  Counters counters = getMyCounters();
  GetCountersResponse response = recordFactory
      .newRecordInstance(GetCountersResponse.class);
  response.setCounters(counters);
  return response;
}

项目：hadoop 文件：MRClientProtocolPBServiceImpl.java

@Override
public GetCountersResponseProto getCounters(RpcController controller,
    GetCountersRequestProto proto) throws ServiceException {
  GetCountersRequest request = new GetCountersRequestPBImpl(proto);
  try {
    GetCountersResponse response = real.getCounters(request);
    return ((GetCountersResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

项目：hadoop 文件：MRClientProtocolPBClientImpl.java

@Override
public GetCountersResponse getCounters(GetCountersRequest request)
    throws IOException {
  GetCountersRequestProto requestProto = ((GetCountersRequestPBImpl)request).getProto();
  try {
    return new GetCountersResponsePBImpl(proxy.getCounters(null, requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}

项目：hadoop 文件：HistoryClientService.java

@Override
public GetCountersResponse getCounters(GetCountersRequest request)
    throws IOException {
  JobId jobId = request.getJobId();
  Job job = verifyAndGetJob(jobId, true);
  GetCountersResponse response = recordFactory.newRecordInstance(GetCountersResponse.class);
  response.setCounters(TypeConverter.toYarn(job.getAllCounters()));
  return response;
}

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

@Override
public GetCountersResponse getCounters(GetCountersRequest request) 
  throws IOException {
  JobId jobId = request.getJobId();
  Job job = verifyAndGetJob(jobId, JobACL.VIEW_JOB, true);
  GetCountersResponse response =
    recordFactory.newRecordInstance(GetCountersResponse.class);
  response.setCounters(TypeConverter.toYarn(job.getAllCounters()));
  return response;
}

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

@Override
public GetCountersResponse getCounters(GetCountersRequest request)
    throws IOException {
  GetCountersResponse resp =
    recordFactory.newRecordInstance(GetCountersResponse.class);
  Counters counters = recordFactory.newRecordInstance(Counters.class);
  counters.addAllCounterGroups(new HashMap<String, CounterGroup>());
  resp.setCounters(counters);
  return resp;
}

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

public org.apache.hadoop.mapreduce.Counters getJobCounters(JobID arg0) throws IOException,
InterruptedException {
  org.apache.hadoop.mapreduce.v2.api.records.JobId jobID = TypeConverter.toYarn(arg0);
    GetCountersRequest request = recordFactory.newRecordInstance(GetCountersRequest.class);
    request.setJobId(jobID);
    Counters cnt = ((GetCountersResponse)
        invoke("getCounters", GetCountersRequest.class, request)).getCounters();
    return TypeConverter.fromYarn(cnt);

}

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

@Override
 public GetCountersResponse getCounters(GetCountersRequest request)
     throws IOException {
   hsContact = true;
   Counters counters = getMyCounters();
   GetCountersResponse response = recordFactory.newRecordInstance(GetCountersResponse.class);
   response.setCounters(counters);
   return response;
}

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

@Override
public GetCountersResponse getCounters(GetCountersRequest request)
    throws IOException {
  JobId jobID = request.getJobId();

  amContact = true;

  Counters counters = getMyCounters();
  GetCountersResponse response = recordFactory
      .newRecordInstance(GetCountersResponse.class);
  response.setCounters(counters);
  return response;
}

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

@Override
public GetCountersResponseProto getCounters(RpcController controller,
    GetCountersRequestProto proto) throws ServiceException {
  GetCountersRequest request = new GetCountersRequestPBImpl(proto);
  try {
    GetCountersResponse response = real.getCounters(request);
    return ((GetCountersResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

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

@Override
public GetCountersResponse getCounters(GetCountersRequest request)
    throws IOException {
  GetCountersRequestProto requestProto = ((GetCountersRequestPBImpl)request).getProto();
  try {
    return new GetCountersResponsePBImpl(proxy.getCounters(null, requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}

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

@Override
public GetCountersResponse getCounters(GetCountersRequest request)
    throws IOException {
  JobId jobId = request.getJobId();
  Job job = verifyAndGetJob(jobId, true);
  GetCountersResponse response = recordFactory.newRecordInstance(GetCountersResponse.class);
  response.setCounters(TypeConverter.toYarn(job.getAllCounters()));
  return response;
}

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

@Override
public GetCountersResponse getCounters(GetCountersRequest request) 
  throws IOException {
  JobId jobId = request.getJobId();
  Job job = verifyAndGetJob(jobId, JobACL.VIEW_JOB, true);
  GetCountersResponse response =
    recordFactory.newRecordInstance(GetCountersResponse.class);
  response.setCounters(TypeConverter.toYarn(job.getAllCounters()));
  return response;
}

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

@Override
public GetCountersResponse getCounters(GetCountersRequest request)
    throws IOException {
  GetCountersResponse resp =
    recordFactory.newRecordInstance(GetCountersResponse.class);
  Counters counters = recordFactory.newRecordInstance(Counters.class);
  counters.addAllCounterGroups(new HashMap<String, CounterGroup>());
  resp.setCounters(counters);
  return resp;
}

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

public org.apache.hadoop.mapreduce.Counters getJobCounters(JobID arg0) throws IOException,
InterruptedException {
  org.apache.hadoop.mapreduce.v2.api.records.JobId jobID = TypeConverter.toYarn(arg0);
    GetCountersRequest request = recordFactory.newRecordInstance(GetCountersRequest.class);
    request.setJobId(jobID);
    Counters cnt = ((GetCountersResponse)
        invoke("getCounters", GetCountersRequest.class, request)).getCounters();
    return TypeConverter.fromYarn(cnt);

}

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

@Override
 public GetCountersResponse getCounters(GetCountersRequest request)
     throws IOException {
   hsContact = true;
   Counters counters = getMyCounters();
   GetCountersResponse response = recordFactory.newRecordInstance(GetCountersResponse.class);
   response.setCounters(counters);
   return response;
}

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

@Override
public GetCountersResponse getCounters(GetCountersRequest request)
    throws IOException {
  JobId jobID = request.getJobId();

  amContact = true;

  Counters counters = getMyCounters();
  GetCountersResponse response = recordFactory
      .newRecordInstance(GetCountersResponse.class);
  response.setCounters(counters);
  return response;
}

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

@Override
public GetCountersResponseProto getCounters(RpcController controller,
    GetCountersRequestProto proto) throws ServiceException {
  GetCountersRequest request = new GetCountersRequestPBImpl(proto);
  try {
    GetCountersResponse response = real.getCounters(request);
    return ((GetCountersResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

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

@Override
public GetCountersResponse getCounters(GetCountersRequest request)
    throws IOException {
  GetCountersRequestProto requestProto = ((GetCountersRequestPBImpl)request).getProto();
  try {
    return new GetCountersResponsePBImpl(proxy.getCounters(null, requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}

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

@Override
public GetCountersResponse getCounters(GetCountersRequest request)
    throws IOException {
  JobId jobId = request.getJobId();
  Job job = verifyAndGetJob(jobId, true);
  GetCountersResponse response = recordFactory.newRecordInstance(GetCountersResponse.class);
  response.setCounters(TypeConverter.toYarn(job.getAllCounters()));
  return response;
}

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

@Override
public GetCountersResponse getCounters(GetCountersRequest request) 
  throws IOException {
  JobId jobId = request.getJobId();
  Job job = verifyAndGetJob(jobId, JobACL.VIEW_JOB);
  GetCountersResponse response =
    recordFactory.newRecordInstance(GetCountersResponse.class);
  response.setCounters(TypeConverter.toYarn(job.getAllCounters()));
  return response;
}

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

@Override
public GetCountersResponse getCounters(GetCountersRequest request)
    throws IOException {
  GetCountersResponse resp =
    recordFactory.newRecordInstance(GetCountersResponse.class);
  Counters counters = recordFactory.newRecordInstance(Counters.class);
  counters.addAllCounterGroups(new HashMap<String, CounterGroup>());
  resp.setCounters(counters);
  return resp;
}

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

public org.apache.hadoop.mapreduce.Counters getJobCounters(JobID arg0) throws IOException,
InterruptedException {
  org.apache.hadoop.mapreduce.v2.api.records.JobId jobID = TypeConverter.toYarn(arg0);
    GetCountersRequest request = recordFactory.newRecordInstance(GetCountersRequest.class);
    request.setJobId(jobID);
    Counters cnt = ((GetCountersResponse)
        invoke("getCounters", GetCountersRequest.class, request)).getCounters();
    return TypeConverter.fromYarn(cnt);

}

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

@Override
 public GetCountersResponse getCounters(GetCountersRequest request)
     throws IOException {
   hsContact = true;
   Counters counters = getMyCounters();
   GetCountersResponse response = recordFactory.newRecordInstance(GetCountersResponse.class);
   response.setCounters(counters);
   return response;
}

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

@Override
public GetCountersResponse getCounters(GetCountersRequest request)
    throws IOException {
  JobId jobID = request.getJobId();

  amContact = true;

  Counters counters = getMyCounters();
  GetCountersResponse response = recordFactory
      .newRecordInstance(GetCountersResponse.class);
  response.setCounters(counters);
  return response;
}

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

@Override
public GetCountersResponseProto getCounters(RpcController controller,
    GetCountersRequestProto proto) throws ServiceException {
  GetCountersRequest request = new GetCountersRequestPBImpl(proto);
  try {
    GetCountersResponse response = real.getCounters(request);
    return ((GetCountersResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

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

@Override
public GetCountersResponse getCounters(GetCountersRequest request)
    throws IOException {
  GetCountersRequestProto requestProto = ((GetCountersRequestPBImpl)request).getProto();
  try {
    return new GetCountersResponsePBImpl(proxy.getCounters(null, requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}

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

@Override
public GetCountersResponse getCounters(GetCountersRequest request)
    throws IOException {
  JobId jobId = request.getJobId();
  Job job = verifyAndGetJob(jobId);
  GetCountersResponse response = recordFactory.newRecordInstance(GetCountersResponse.class);
  response.setCounters(TypeConverter.toYarn(job.getAllCounters()));
  return response;
}

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

@Override
public GetCountersResponse getCounters(GetCountersRequest request) 
  throws IOException {
  JobId jobId = request.getJobId();
  Job job = verifyAndGetJob(jobId, false);
  GetCountersResponse response =
    recordFactory.newRecordInstance(GetCountersResponse.class);
  response.setCounters(TypeConverter.toYarn(job.getAllCounters()));
  return response;
}

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

@Override
public GetCountersResponse getCounters(GetCountersRequest request)
    throws IOException {
  GetCountersResponse resp =
    recordFactory.newRecordInstance(GetCountersResponse.class);
  Counters counters = recordFactory.newRecordInstance(Counters.class);
  counters.addAllCounterGroups(new HashMap<String, CounterGroup>());
  resp.setCounters(counters);
  return resp;
}

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

public org.apache.hadoop.mapreduce.Counters getJobCounters(JobID arg0) throws IOException,
InterruptedException {
  org.apache.hadoop.mapreduce.v2.api.records.JobId jobID = TypeConverter.toYarn(arg0);
    GetCountersRequest request = recordFactory.newRecordInstance(GetCountersRequest.class);
    request.setJobId(jobID);
    Counters cnt = ((GetCountersResponse)
        invoke("getCounters", GetCountersRequest.class, request)).getCounters();
    return TypeConverter.fromYarn(cnt);

}

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

@Override
 public GetCountersResponse getCounters(GetCountersRequest request)
     throws IOException {
   hsContact = true;
   Counters counters = getMyCounters();
   GetCountersResponse response = recordFactory.newRecordInstance(GetCountersResponse.class);
   response.setCounters(counters);
   return response;
}

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

@Override
public GetCountersResponse getCounters(GetCountersRequest request)
    throws IOException {
  JobId jobID = request.getJobId();

  amContact = true;

  Counters counters = getMyCounters();
  GetCountersResponse response = recordFactory
      .newRecordInstance(GetCountersResponse.class);
  response.setCounters(counters);
  return response;
}

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

@Override
public GetCountersResponseProto getCounters(RpcController controller,
    GetCountersRequestProto proto) throws ServiceException {
  GetCountersRequest request = new GetCountersRequestPBImpl(proto);
  try {
    GetCountersResponse response = real.getCounters(request);
    return ((GetCountersResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

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

@Override
public GetCountersResponse getCounters(GetCountersRequest request)
    throws IOException {
  GetCountersRequestProto requestProto = ((GetCountersRequestPBImpl)request).getProto();
  try {
    return new GetCountersResponsePBImpl(proxy.getCounters(null, requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}

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

@Override
public GetCountersResponse getCounters(GetCountersRequest request)
    throws IOException {
  JobId jobId = request.getJobId();
  Job job = verifyAndGetJob(jobId);
  GetCountersResponse response = recordFactory.newRecordInstance(GetCountersResponse.class);
  response.setCounters(TypeConverter.toYarn(job.getAllCounters()));
  return response;
}