Searched refs:RUN_REDUCE (Results 1 – 4 of 4) sorted by relevance
| /dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapred/pipes/ |
| H A D | BinaryProtocol.java | 71 RUN_REDUCE(5), enumConstant
313 WritableUtils.writeVInt(stream, MessageType.RUN_REDUCE.code); in runReduce()
|
| /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/pipes/ |
| H A D | BinaryProtocol.java | 75 RUN_REDUCE(5), enumConstant
317 WritableUtils.writeVInt(stream, MessageType.RUN_REDUCE.code); in runReduce()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-pipes/src/main/native/pipes/impl/ |
| H A D | HadoopPipes.cc | 298 MAP_ITEM, RUN_REDUCE, REDUCE_KEY, REDUCE_VALUE, enumerator
536 case RUN_REDUCE: { in nextEvent()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/c++/pipes/impl/ |
| H A D | HadoopPipes.cc | 298 MAP_ITEM, RUN_REDUCE, REDUCE_KEY, REDUCE_VALUE, enumerator
536 case RUN_REDUCE: { in nextEvent()
|