linux eclipse3.6.1 maven安装

hadoop-commonhadoop-hdfshadoop-mapreduce-client-corehadoop-mapreduce-client-jobclienthadoop-mapreduce-client-common

<dependencies>        <dependency>            <groupId>org.apache.hadoop</groupId>            <artifactId>hadoop-common</artifactId>            <version>2.5.2</version>        </dependency>        <dependency>            <groupId>org.apache.hadoop</groupId>            <artifactId>hadoop-hdfs</artifactId>            <version>2.5.2</version>        </dependency>        <dependency>            <groupId>org.apache.hadoop</groupId>            <artifactId>hadoop-mapreduce-client-core</artifactId>            <version>2.5.2</version>        </dependency>        <dependency>            <groupId>org.apache.hadoop</groupId>            <artifactId>hadoop-mapreduce-client-jobclient</artifactId>            <version>2.5.2</version>        </dependency>        <dependency>            <groupId>org.apache.hadoop</groupId>            <artifactId>hadoop-mapreduce-client-common</artifactId>            <version>2.5.2</version>        </dependency>        <dependency>            <groupId>jdk.tools</groupId>            <artifactId>jdk.tools</artifactId>            <version>1.7</version>            <scope>system</scope>            <systemPath>${JAVA_HOME}/lib/tools.jar</systemPath>        </dependency>    </dependencies>

package firstExample;import java.io.IOException;import java.util.StringTokenizer;import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.fs.Path;import org.apache.hadoop.io.IntWritable;import org.apache.hadoop.io.Text;import org.apache.hadoop.mapreduce.Job;import org.apache.hadoop.mapreduce.Mapper;import org.apache.hadoop.mapreduce.Reducer;import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat;public class WordCountEx {	static class MyMapper extends Mapper<Object, Text, Text, IntWritable> {		private final static IntWritable one = new IntWritable(1);		private Text word = new Text();		protected void map(				Object key,				Text value,				org.apache.hadoop.mapreduce.Mapper<Object, Text, Text, IntWritable>.Context context)				throws java.io.IOException, InterruptedException {			// 分隔字符串			StringTokenizer itr = new StringTokenizer(value.toString());			while (itr.hasMoreTokens()) {				// 排除字母少于5个字				String tmp = itr.nextToken();				if (tmp.length() < 5) {					continue;				}				word.set(tmp);				context.write(word, one);			}		}	}	static class MyReduce extends Reducer<Text, IntWritable, Text, IntWritable> {		private IntWritable result = new IntWritable();		private Text keyEx = new Text();		protected void reduce(				Text key,				java.lang.Iterable<IntWritable> values,				org.apache.hadoop.mapreduce.Reducer<Text, IntWritable, Text, IntWritable>.Context context)				throws java.io.IOException, InterruptedException {						int sum=0;			for (IntWritable val:values) {				//				sum+= val.get()*2;			}						result.set(sum);			//自定义输出key						keyEx.set("输出:"+key.toString());			context.write(keyEx, result);					}	}		public static void main(String[] args) throws IOException, ClassNotFoundException, InterruptedException {		//配置信息		Configuration conf=new Configuration();				//job的名称		Job job=Job.getInstance(conf,"mywordcount");				job.setJarByClass(WordCountEx.class);		job.setMapperClass(MyMapper.class);				job.setReducerClass(MyReduce.class);		job.setOutputKeyClass(Text.class);		job.setOutputValueClass(IntWritable.class);				//输入, 输出path		FileInputFormat.addInputPath(job, new Path(args[0]));		FileOutputFormat.setOutputPath(job, new Path(args[1]));				//结束		System.out.println(job.waitForCompletion(true)?0:1);			}			}