如何手写一个map端join的案例？

首先需要在main方法中添加分布式缓存文件

job.addCacheFile(new URI("/wordcount/cache/user.txt"))

接着重写setup方法

在setup方法当中读取本地文件（这里的本地 是指执行maptask的机器本地）

@Override protected void setup(Context context) throws IOException, InterruptedException { BufferedReader br = new BufferedReader(new FileReader("user.txt"));

    String line = null;
    while((line=br.readLine())!=null){
        String[] arr = line.split(",");
        Order user = new Order();
        user.set("",null,arr[0],null,arr[1],arr[2]);
        userMap.put(user.getUid(),user);
    }