| | 102 | {{{ |
| | 103 | $HADOOP_HOME/bin/hadoop jar $HADOOP_HOME/hadoop-streaming.jar \ |
| | 104 | -D map.output.key.field.separa=. \ |
| | 105 | -D mapred.text.key.partitioner.options=-k1,2 \ |
| | 106 | -D mapred.data.field.separator=. \ |
| | 107 | -D map.output.key.value.fields.spec=6,5,1-3:0- \ |
| | 108 | -D reduce.output.key.value.fields.spec=0-2:5- \ |
| | 109 | -D mapred.reduce.tasks=12 \ |
| | 110 | -input myInputDirs \ |
| | 111 | -output myOutputDir \ |
| | 112 | -mapper org.apache.hadoop.mapred.lib.FieldSelectionMapReduce \ |
| | 113 | -reducer org.apache.hadoop.mapred.lib.FieldSelectionMapReduce \ |
| | 114 | -partitioner org.apache.hadoop.mapred.lib.KeyFieldBasedPartitioner |
| | 115 | }}} |
| | 116 | |
| | 117 | |
| | 118 | ---- |
| | 119 | |