| /dports/devel/hadoop/hadoop-1.2.1/src/contrib/gridmix/src/java/org/apache/hadoop/mapred/gridmix/ |
| H A D | JobFactory.java | 114 super(info.getInputBytes(), info.getInputRecords(), in MinTaskInfo()
118 public long getInputBytes() { in getInputBytes() method in JobFactory.MinTaskInfo
119 return Math.max(0, super.getInputBytes()); in getInputBytes()
|
| H A D | LoadJob.java | 588 mapInputBytesTotal += info.getInputBytes(); in buildSplits()
596 reduceByteRatio[i] = info.getInputBytes() / (1.0 * mapOutputBytesTotal); in buildSplits()
624 info.getInputBytes(), 3), maps, i, in buildSplits()
625 info.getInputBytes(), info.getInputRecords(), in buildSplits()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-gridmix/src/main/java/org/apache/hadoop/mapred/gridmix/ |
| H A D | JobFactory.java | 116 super(info.getInputBytes(), info.getInputRecords(), in MinTaskInfo()
120 public long getInputBytes() { in getInputBytes() method in JobFactory.MinTaskInfo
121 return Math.max(0, super.getInputBytes()); in getInputBytes()
|
| H A D | LoadJob.java | 612 mapInputBytesTotal += info.getInputBytes(); in buildSplits()
620 reduceByteRatio[i] = info.getInputBytes() / (1.0 * mapOutputBytesTotal); in buildSplits()
648 long possiblyCompressedInputBytes = info.getInputBytes(); in buildSplits()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapred/ |
| H A D | MapTask.java | 190 bytesInPrev = getInputBytes(fsStats); in TrackedRecordReader()
192 bytesInCurr = getInputBytes(fsStats); in TrackedRecordReader()
229 bytesInPrev = getInputBytes(fsStats); in moveToNext()
232 bytesInCurr = getInputBytes(fsStats); in moveToNext()
247 bytesInPrev = getInputBytes(fsStats); in close()
249 bytesInCurr = getInputBytes(fsStats); in close()
487 long bytesInPrev = getInputBytes(fsStats); in NewTrackingRecordReader()
489 long bytesInCurr = getInputBytes(fsStats); in NewTrackingRecordReader()
495 long bytesInPrev = getInputBytes(fsStats); in close()
497 long bytesInCurr = getInputBytes(fsStats); in close()
[all …]
|
| /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 | MapTask.java | 168 bytesInPrev = getInputBytes(fsStats); in TrackedRecordReader()
171 bytesInCurr = getInputBytes(fsStats); in TrackedRecordReader()
198 bytesInPrev = getInputBytes(fsStats); in moveToNext()
200 bytesInCurr = getInputBytes(fsStats); in moveToNext()
209 bytesInPrev = getInputBytes(fsStats); in close()
211 bytesInCurr = getInputBytes(fsStats); in close()
514 long bytesInPrev = getInputBytes(fsStats); in NewTrackingRecordReader()
516 long bytesInCurr = getInputBytes(fsStats); in NewTrackingRecordReader()
522 long bytesInPrev = getInputBytes(fsStats); in close()
524 long bytesInCurr = getInputBytes(fsStats); in close()
[all …]
|
| /dports/www/owncloud/owncloud/apps/files_external/3rdparty/google/apiclient-services/src/Google/Service/Bigquery/ |
| H A D | JobStatistics4.php | 36 public function getInputBytes() function in Google_Service_Bigquery_JobStatistics4
|
| /dports/www/orangehrm/orangehrm-4.9/symfony/lib/vendor/google/apiclient-services/src/Google/Service/Bigquery/ |
| H A D | JobStatistics4.php | 36 public function getInputBytes() function in Google_Service_Bigquery_JobStatistics4
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-rumen/src/main/java/org/apache/hadoop/tools/rumen/ |
| H A D | TaskInfo.java | 48 public long getInputBytes() { in getInputBytes() method in TaskInfo
|
| H A D | LoggedTask.java | 82 public long getInputBytes() { in getInputBytes() method in LoggedTask
|
| H A D | ZombieJob.java | 181 long mapInputBytes = getTaskInfo(mapTask).getInputBytes(); in getInputSplits()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/tools/org/apache/hadoop/tools/rumen/ |
| H A D | TaskInfo.java | 48 public long getInputBytes() { in getInputBytes() method in TaskInfo
|
| H A D | LoggedTask.java | 77 public long getInputBytes() { in getInputBytes() method in LoggedTask
|
| H A D | ZombieJob.java | 179 long mapInputBytes = getTaskInfo(mapTask).getInputBytes(); in getInputSplits()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/tools/rumen/ |
| H A D | TestZombieJob.java | 233 assertEquals(mapTaskCounts[0], mapTask.getInputBytes()); in testRecordIOInfo()
239 assertEquals(reduceTaskCounts[0], reduceTask.getInputBytes()); in testRecordIOInfo()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-gridmix/src/test/java/org/apache/hadoop/mapred/gridmix/ |
| H A D | CommonJobTest.java | 229 specInputBytes[i] = specInfo.getInputBytes(); in check()
260 specInfo.getInputBytes(), specOutputBytes[i], in check()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/contrib/gridmix/src/test/org/apache/hadoop/mapred/gridmix/ |
| H A D | TestGridmixSubmission.java | 231 specInputBytes[i] = specInfo.getInputBytes(); in check()
263 specInfo.getInputBytes(), specOutputBytes[i], in check()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/contrib/gridmix/src/test/system/org/apache/hadoop/mapred/gridmix/test/system/ |
| H A D | GridmixJobVerification.java | 283 expMapInputBytes += mapTask.getInputBytes(); in getJobMapCounters()
308 expReduceInputBytes += reduceTask.getInputBytes(); in getJobReduceCounters()
|