| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/records/impl/pb/ |
| H A D | JobReportPBImpl.java | 46 private List<AMInfo> amInfos = null; field in JobReportPBImpl
69 if (this.amInfos != null) { in mergeLocalToBuilder()
271 return this.amInfos; in getAMInfos()
277 if (amInfos == null) { in setAMInfos()
279 this.amInfos = null; in setAMInfos()
283 this.amInfos.clear(); in setAMInfos()
284 this.amInfos.addAll(amInfos); in setAMInfos()
289 if (this.amInfos != null) { in initAMInfos()
295 this.amInfos = new ArrayList<AMInfo>(); in initAMInfos()
305 if (this.amInfos == null) in addAMInfosToProto()
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/test/java/org/apache/hadoop/mapreduce/v2/app/ |
| H A D | TestAMInfos.java | 78 List<AMInfo> amInfos = app.getAllAMInfos(); in testAMInfosWithoutRecoveryEnabled() local
79 Assert.assertEquals(2, amInfos.size()); in testAMInfosWithoutRecoveryEnabled()
80 AMInfo amInfoOne = amInfos.get(0); in testAMInfosWithoutRecoveryEnabled()
|
| H A D | TestMRClientService.java | 275 List<AMInfo> amInfos = jr.getAMInfos(); in verifyJobReport() local
276 Assert.assertEquals(1, amInfos.size()); in verifyJobReport()
278 AMInfo amInfo = amInfos.get(0); in verifyJobReport()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/webapp/ |
| H A D | NavBlock.java | 54 List<AMInfo> amInfos = app.getJob().getAMInfos(); in render() local
55 AMInfo thisAmInfo = amInfos.get(amInfos.size()-1); in render()
|
| H A D | JobBlock.java | 74 List<AMInfo> amInfos = job.getAMInfos(); in render() local
76 amInfos.size() == 1 ? "ApplicationMaster" : "ApplicationMasters"; in render()
101 for (AMInfo amInfo : amInfos) { in render()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapreduce/v2/ |
| H A D | TestMRJobsWithHistoryService.java | 168 List<AMInfo> amInfos = jobReport.getAMInfos(); in verifyJobReport() local
169 Assert.assertEquals(1, amInfos.size()); in verifyJobReport()
170 AMInfo amInfo = amInfos.get(0); in verifyJobReport()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/jobhistory/ |
| H A D | JobHistoryParser.java | 420 if (info.amInfos == null) { in handleAMStartedEvent()
421 info.amInfos = new LinkedList<AMInfo>(); in handleAMStartedEvent()
423 info.amInfos.add(amInfo); in handleAMStartedEvent()
470 List<AMInfo> amInfos; field in JobHistoryParser.JobInfo
509 if (amInfos != null) { in printAll()
510 for (AMInfo amInfo : amInfos) { in printAll()
566 public List<AMInfo> getAMInfos() { return amInfos; } in getAMInfos()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/util/ |
| H A D | MRBuilderUtils.java | 68 float cleanupProgress, String jobFile, List<AMInfo> amInfos, in newJobReport() argument
83 report.setAMInfos(amInfos); in newJobReport()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/ |
| H A D | MRAppMaster.java | 192 private List<AMInfo> amInfos; field in MRAppMaster
792 return amInfos;
1037 amInfos = new LinkedList<AMInfo>();
1052 for (AMInfo info : amInfos) {
1067 amInfos.add(amInfo);
1179 amInfos.addAll(readJustAMInfos());
1189 amInfos.addAll(readJustAMInfos());
1242 amInfos.add(amInfo);
1248 List<AMInfo> amInfos = new ArrayList<AMInfo>();
1266 amInfos.add(MRBuilderUtils.newAMInfo(
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-hs/src/main/java/org/apache/hadoop/mapreduce/v2/hs/webapp/ |
| H A D | HsJobBlock.java | 79 List<AMInfo> amInfos = j.getAMInfos(); in render() local
94 amInfos.size() == 1 ? "ApplicationMaster" : "ApplicationMasters"; in render()
135 for (AMInfo amInfo : amInfos) { in render()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/records/ |
| H A D | JobReport.java | 55 public abstract void setAMInfos(List<AMInfo> amInfos); in setAMInfos() argument
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-hs/src/main/java/org/apache/hadoop/mapreduce/v2/hs/ |
| H A D | CompletedJob.java | 453 List<AMInfo> amInfos = new LinkedList<AMInfo>(); in getAMInfos() local
462 amInfos.add(amInfo); in getAMInfos()
464 return amInfos; in getAMInfos()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/job/impl/ |
| H A D | JobImpl.java | 170 private final List<AMInfo> amInfos; field in JobImpl
663 long appSubmitTime, List<AMInfo> amInfos, AppContext appContext, in JobImpl() argument
672 this.amInfos = amInfos; in JobImpl()
873 cleanupProgress, jobFile, amInfos, isUber, diagsb.toString()); in getReport()
880 cleanupProgress, jobFile, amInfos, isUber, diagsb.toString()); in getReport()
1193 return amInfos; in getAMInfos()
|