Hadoop(最新版ChainMapper链接MapReduce作业带原理分析)

package com.zzg.test1;
import java.io.IOException;
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Mapper;

public class MapClass1 extends Mapper<LongWritable, Text, Text, Text> {

	public void map(LongWritable ikey, Text ivalue, Context context) throws IOException, InterruptedException {
		 String[] citation=ivalue.toString().split(" ");
         if(!citation[0].equals("100"))
         {
        	 context.write(new Text(citation[0]), new Text(ivalue));
         }
	}

}
package com.zzg.test1;
import java.io.IOException;