Examples of JobReportProtoOrBuilder

Examples of org.apache.hadoop.mapreduce.v2.proto.MRProtos.JobReportProtoOrBuilder

287
288
289
290
291
292
293
294
295
296
297
298
 
  private synchronized void initAMInfos() {
    if (this.amInfos != null) {
      return;
    }
    JobReportProtoOrBuilder p = viaProto ? proto : builder;
    List<AMInfoProto> list = p.getAmInfosList();
   
    this.amInfos = new ArrayList<AMInfo>();

    for (AMInfoProto amInfoProto : list) {
      this.amInfos.add(convertFromProtoFormat(amInfoProto));
View Full Code Here

Examples of org.apache.hadoop.mapreduce.v2.proto.MRProtos.JobReportProtoOrBuilder

87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
  }
   
 
  @Override
  public synchronized JobId getJobId() {
    JobReportProtoOrBuilder p = viaProto ? proto : builder;
    if (this.jobId != null) {
      return this.jobId;
    }
    if (!p.hasJobId()) {
      return null;
    }
    this.jobId = convertFromProtoFormat(p.getJobId());
    return this.jobId;
  }
View Full Code Here

Examples of org.apache.hadoop.mapreduce.v2.proto.MRProtos.JobReportProtoOrBuilder

107
108
109
110
111
112
113
114
115
116
117
      builder.clearJobId();
    this.jobId = jobId;
  }
  @Override
  public synchronized JobState getJobState() {
    JobReportProtoOrBuilder p = viaProto ? proto : builder;
    if (!p.hasJobState()) {
      return null;
    }
    return convertFromProtoFormat(p.getJobState());
  }
View Full Code Here

Examples of org.apache.hadoop.mapreduce.v2.proto.MRProtos.JobReportProtoOrBuilder

125
126
127
128
129
130
131
132
    }
    builder.setJobState(convertToProtoFormat(jobState));
  }
  @Override
  public synchronized float getMapProgress() {
    JobReportProtoOrBuilder p = viaProto ? proto : builder;
    return (p.getMapProgress());
  }
View Full Code Here

Examples of org.apache.hadoop.mapreduce.v2.proto.MRProtos.JobReportProtoOrBuilder

136
137
138
139
140
141
142
143
    maybeInitBuilder();
    builder.setMapProgress((mapProgress));
  }
  @Override
  public synchronized float getReduceProgress() {
    JobReportProtoOrBuilder p = viaProto ? proto : builder;
    return (p.getReduceProgress());
  }
View Full Code Here

Examples of org.apache.hadoop.mapreduce.v2.proto.MRProtos.JobReportProtoOrBuilder

147
148
149
150
151
152
153
154
    maybeInitBuilder();
    builder.setReduceProgress((reduceProgress));
  }
  @Override
  public synchronized float getCleanupProgress() {
    JobReportProtoOrBuilder p = viaProto ? proto : builder;
    return (p.getCleanupProgress());
  }
View Full Code Here

Examples of org.apache.hadoop.mapreduce.v2.proto.MRProtos.JobReportProtoOrBuilder

158
159
160
161
162
163
164
165
    maybeInitBuilder();
    builder.setCleanupProgress((cleanupProgress));
  }
  @Override
  public synchronized float getSetupProgress() {
    JobReportProtoOrBuilder p = viaProto ? proto : builder;
    return (p.getSetupProgress());
  }
View Full Code Here

Examples of org.apache.hadoop.mapreduce.v2.proto.MRProtos.JobReportProtoOrBuilder

170
171
172
173
174
175
176
177
    builder.setSetupProgress((setupProgress));
  }

  @Override
  public synchronized long getSubmitTime() {
    JobReportProtoOrBuilder p = viaProto ? proto : builder;
    return (p.getSubmitTime());
  }
View Full Code Here

Examples of org.apache.hadoop.mapreduce.v2.proto.MRProtos.JobReportProtoOrBuilder

182
183
184
185
186
187
188
189
    builder.setSubmitTime((submitTime));
  }

  @Override
  public synchronized long getStartTime() {
    JobReportProtoOrBuilder p = viaProto ? proto : builder;
    return (p.getStartTime());
  }
View Full Code Here

Examples of org.apache.hadoop.mapreduce.v2.proto.MRProtos.JobReportProtoOrBuilder

193
194
195
196
197
198
199
200
    maybeInitBuilder();
    builder.setStartTime((startTime));
  }
  @Override
  public synchronized long getFinishTime() {
    JobReportProtoOrBuilder p = viaProto ? proto : builder;
    return (p.getFinishTime());
  }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.