package cn.jecn.hadoop.mapreduce.com;

import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Mapper;
import org.apache.hadoop.mrunit.mapreduce.MapDriver;
import org.junit.Before;
import org.junit.Test;
@SuppressWarnings("all")
public class MapTest {
    
	private Mapper mapper;
    private MapDriver driver;
  
    @Before
    public void init(){
    	mapper= new MapperClass();
    	driver=new MapDriver(mapper);
    }
    
    @Test
    public void test(){
    	String line="Taobao is a great website";
    	driver.withInput(null,new Text(line))
    	      .withOutput(new Text("Taobao"), new IntWritable(1))
    	      .withOutput(new Text("is"), new IntWritable(1))
    	      .withOutput(new Text("a"), new IntWritable(1))
    	      .withOutput(new Text("great"), new IntWritable(1))
    	      .withOutput(new Text("website"), new IntWritable(1)).runTest();
    	
    }
	
}