Java 类org.apache.hadoop.mapreduce.v2.api.records.impl.pb.TaskAttemptReportPBImpl 实例源码

@Test
public void testBuildImplicitRawCounters() {
  TaskAttemptReportPBImpl report = new TaskAttemptReportPBImpl();
  org.apache.hadoop.mapreduce.Counters rCounters = MockJobs.newCounters();
  report.setRawCounters(rCounters);
  MRProtos.TaskAttemptReportProto protoVal = report.getProto();
  Counters counters = report.getCounters();
  assertTrue(protoVal.hasCounters());
}

@Test
public void testBuildImplicitRawCounters() {
  TaskAttemptReportPBImpl report = new TaskAttemptReportPBImpl();
  org.apache.hadoop.mapreduce.Counters rCounters = MockJobs.newCounters();
  report.setRawCounters(rCounters);
  MRProtos.TaskAttemptReportProto protoVal = report.getProto();
  Counters counters = report.getCounters();
  assertTrue(protoVal.hasCounters());
}

private TaskAttemptReportPBImpl convertFromProtoFormat(TaskAttemptReportProto p) {
  return new TaskAttemptReportPBImpl(p);
}

private TaskAttemptReportProto convertToProtoFormat(TaskAttemptReport t) {
  return ((TaskAttemptReportPBImpl)t).getProto();
}

private TaskAttemptReportPBImpl convertFromProtoFormat(TaskAttemptReportProto p) {
  return new TaskAttemptReportPBImpl(p);
}

private TaskAttemptReportProto convertToProtoFormat(TaskAttemptReport t) {
  return ((TaskAttemptReportPBImpl)t).getProto();
}

private TaskAttemptReportPBImpl convertFromProtoFormat(TaskAttemptReportProto p) {
  return new TaskAttemptReportPBImpl(p);
}

private TaskAttemptReportProto convertToProtoFormat(TaskAttemptReport t) {
  return ((TaskAttemptReportPBImpl)t).getProto();
}

private TaskAttemptReportPBImpl convertFromProtoFormat(TaskAttemptReportProto p) {
  return new TaskAttemptReportPBImpl(p);
}

private TaskAttemptReportProto convertToProtoFormat(TaskAttemptReport t) {
  return ((TaskAttemptReportPBImpl)t).getProto();
}

private TaskAttemptReportPBImpl convertFromProtoFormat(TaskAttemptReportProto p) {
  return new TaskAttemptReportPBImpl(p);
}

private TaskAttemptReportProto convertToProtoFormat(TaskAttemptReport t) {
  return ((TaskAttemptReportPBImpl)t).getProto();
}

private TaskAttemptReportPBImpl convertFromProtoFormat(TaskAttemptReportProto p) {
  return new TaskAttemptReportPBImpl(p);
}

private TaskAttemptReportProto convertToProtoFormat(TaskAttemptReport t) {
  return ((TaskAttemptReportPBImpl)t).getProto();
}

private TaskAttemptReportPBImpl convertFromProtoFormat(TaskAttemptReportProto p) {
  return new TaskAttemptReportPBImpl(p);
}

private TaskAttemptReportProto convertToProtoFormat(TaskAttemptReport t) {
  return ((TaskAttemptReportPBImpl)t).getProto();
}

private TaskAttemptReportPBImpl convertFromProtoFormat(TaskAttemptReportProto p) {
  return new TaskAttemptReportPBImpl(p);
}

private TaskAttemptReportProto convertToProtoFormat(TaskAttemptReport t) {
  return ((TaskAttemptReportPBImpl)t).getProto();
}

private TaskAttemptReportPBImpl convertFromProtoFormat(TaskAttemptReportProto p) {
  return new TaskAttemptReportPBImpl(p);
}

private TaskAttemptReportProto convertToProtoFormat(TaskAttemptReport t) {
  return ((TaskAttemptReportPBImpl)t).getProto();
}

private TaskAttemptReportPBImpl convertFromProtoFormat(TaskAttemptReportProto p) {
  return new TaskAttemptReportPBImpl(p);
}

private TaskAttemptReportProto convertToProtoFormat(TaskAttemptReport t) {
  return ((TaskAttemptReportPBImpl)t).getProto();
}