| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/ |
| H A D | JobStatus.java | 82 public JobStatus(JobID jobid, float mapProgress, float reduceProgress, in JobStatus()
96 public JobStatus(JobID jobid, float mapProgress, float reduceProgress, in JobStatus()
110 public JobStatus(JobID jobid, float mapProgress, float reduceProgress, in JobStatus()
128 float reduceProgress, float cleanupProgress, in JobStatus()
146 public JobStatus(JobID jobid, float mapProgress, float reduceProgress, in JobStatus()
165 public JobStatus(JobID jobid, float mapProgress, float reduceProgress, in JobStatus()
208 float reduceProgress, float cleanupProgress, in JobStatus()
231 float reduceProgress, float cleanupProgress, in JobStatus()
254 float reduceProgress, float cleanupProgress, in JobStatus()
280 float reduceProgress, float cleanupProgress, in JobStatus()
[all …]
|
| H A D | RunningJob.java | 99 public float reduceProgress() throws IOException; in reduceProgress() method
|
| H A D | JobClient.java | 244 public float reduceProgress() throws IOException { in reduceProgress() method in JobClient.NetworkedJob
|
| /dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapred/ |
| H A D | JobStatus.java | 79 private float reduceProgress; field in JobStatus
102 public JobStatus(JobID jobid, float mapProgress, float reduceProgress, in JobStatus()
115 public JobStatus(JobID jobid, float mapProgress, float reduceProgress, in JobStatus()
128 public JobStatus(JobID jobid, float mapProgress, float reduceProgress, in JobStatus()
145 float reduceProgress, float cleanupProgress, in JobStatus()
222 public synchronized float reduceProgress() { return reduceProgress; } in reduceProgress() method in JobStatus
|
| H A D | RunningJob.java | 85 public float reduceProgress() throws IOException; in reduceProgress() method
|
| H A D | JobClient.java | 294 public float reduceProgress() throws IOException { in reduceProgress() method in JobClient.NetworkedJob
|
| /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/ |
| H A D | JobStatus.java | 76 private float reduceProgress; field in JobStatus
123 float reduceProgress, float cleanupProgress, in JobStatus()
146 float reduceProgress, float cleanupProgress, in JobStatus()
171 float reduceProgress, float cleanupProgress, in JobStatus()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/contrib/gridmix/src/java/org/apache/hadoop/mapred/gridmix/ |
| H A D | StressJobFactory.java | 239 int numReduces, float reduceProgress) { in calcEffectiveIncompleteReduceTasks()
295 float reduceProgress = job.getJob().reduceProgress(); in checkLoadAndGetSlotsToBackfill() local
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-gridmix/src/main/java/org/apache/hadoop/mapred/gridmix/ |
| H A D | StressJobFactory.java | 289 int numReduces, float reduceProgress) { in calcEffectiveIncompleteReduceTasks()
388 float reduceProgress = 0f; in checkLoadAndGetSlotsToBackfill() local
|
| /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 | 67 float setupProgress, float mapProgress, float reduceProgress, in newJobReport()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/contrib/eclipse-plugin/src/java/org/apache/hadoop/eclipse/server/ |
| H A D | HadoopJob.java | 117 float reduceProgress; field in HadoopJob
|
| /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/dao/ |
| H A D | JobInfo.java | 61 protected float reduceProgress; field in JobInfo
|
| /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 | 146 public synchronized void setReduceProgress(float reduceProgress) { in setReduceProgress()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapreduce/ |
| H A D | Job.java | 392 public float reduceProgress() throws IOException { in reduceProgress() method in Job
|
| /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 | 640 private float reduceProgress; field in JobImpl
904 float reduceProgress = 0f; in computeProgress() local
|
| /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/webapp/ |
| H A D | TestAMWebServicesJobs.java | 552 float reduceProgress, float mapProgress) { in verifyAMJobGeneric()
|