| /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/task/reduce/ |
| H A D | OnDiskMapOutput.java | 59 public OnDiskMapOutput(TaskAttemptID mapId, TaskAttemptID reduceId, in OnDiskMapOutput()
71 OnDiskMapOutput(TaskAttemptID mapId, TaskAttemptID reduceId, in OnDiskMapOutput()
|
| H A D | ShuffleClientMetrics.java | 42 ShuffleClientMetrics(TaskAttemptID reduceId, JobConf jobConf) { in ShuffleClientMetrics()
|
| H A D | LocalFetcher.java | 54 public LocalFetcher(JobConf job, TaskAttemptID reduceId, in LocalFetcher()
|
| H A D | ShuffleSchedulerImpl.java | 78 private final TaskAttemptID reduceId; field in ShuffleSchedulerImpl
111 TaskAttemptID reduceId, in ShuffleSchedulerImpl()
170 static URI getBaseURI(TaskAttemptID reduceId, String url) { in getBaseURI()
|
| H A D | Shuffle.java | 48 private TaskAttemptID reduceId; field in Shuffle
|
| H A D | Fetcher.java | 107 public Fetcher(JobConf job, TaskAttemptID reduceId, in Fetcher()
116 Fetcher(JobConf job, TaskAttemptID reduceId, in Fetcher()
|
| H A D | MergeManagerImpl.java | 77 private final TaskAttemptID reduceId; field in MergeManagerImpl
132 public MergeManagerImpl(TaskAttemptID reduceId, JobConf jobConf, in MergeManagerImpl()
|
| /dports/devel/spark/spark-2.1.1/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ |
| H A D | ShuffleIndexInformation.java | 53 public ShuffleIndexRecord getIndex(int reduceId) { in getIndex()
|
| H A D | ExternalShuffleBlockResolver.java | 166 int reduceId = Integer.parseInt(blockIdParts[3]); in getBlockData() local
240 ExecutorShuffleInfo executor, int shuffleId, int mapId, int reduceId) { in getSortBasedShuffleBlockData()
|
| /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 | ShuffleConsumerPlugin.java | 50 private final org.apache.hadoop.mapreduce.TaskAttemptID reduceId; field in ShuffleConsumerPlugin.Context
72 public Context(org.apache.hadoop.mapreduce.TaskAttemptID reduceId, in Context()
|
| /dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/shuffle/ |
| H A D | BlockStoreShuffleReaderSuite.scala | 67 val reduceId = 15 constant
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/task/reduce/ |
| H A D | TestFetcher.java | 670 public FakeFetcher(JobConf job, TaskAttemptID reduceId, in FakeFetcher()
680 public FakeFetcher(JobConf job, TaskAttemptID reduceId, in FakeFetcher()
691 public FakeFetcher(JobConf job, TaskAttemptID reduceId, in FakeFetcher()
|
| H A D | TestShuffleScheduler.java | 61 TaskAttemptID reduceId = new TaskAttemptID("314159", 0, TaskType.REDUCE, in testTipFailed() local
|
| /dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/ui/ |
| H A D | UISeleniumSuite.scala | 277 val reduceId = taskContext.partitionId() constant
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-shuffle/src/main/java/org/apache/hadoop/mapred/ |
| H A D | ShuffleHandler.java | 292 private int reduceId; field in ShuffleHandler.ReduceContext
869 int reduceId; in messageReceived() local
|
| /dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapred/ |
| H A D | LocalJobRunner.java | 358 TaskAttemptID reduceId = in run() local
|
| H A D | ReduceTask.java | 1391 TaskAttemptID reduceId = reduceTask.getTaskID(); in copyOutput() local
|
| H A D | TaskTracker.java | 3998 String reduceId = request.getParameter("reduce"); in doGet() 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/mapred/ |
| H A D | LocalJobRunner.java | 300 TaskAttemptID reduceId = new TaskAttemptID(new TaskID( in run() local
|
| /dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/util/ |
| H A D | JsonProtocol.scala | 852 val reduceId = (json \ "Reduce ID").extract[Int] constant
|
| /dports/devel/kdev-php/kdev-php-21.12.3/ |
| H A D | phpfunctions.php | 137537 public $reduceId; variable in Parle\\Parser
137864 public $reduceId; variable in Parle\\RParser
|