@@ -0,0 +1,623 @@
+package com.example.apriori;%0A%0Aimport java.io.IOException;%0A%0Aimport org.apache.hadoop.io.IntWritable;%0Aimport org.apache.hadoop.io.Text;%0Aimport org.apache.hadoop.mapreduce.Mapper;%0Aimport org.apache.hadoop.mapreduce.Mapper.Context;%0A%0Apublic class Map_1itemset extends Mapper%3CObject, Text, Text, IntWritable%3E%7B%0A%09private Text item = new Text();%0A%09private final static IntWritable ONE = new IntWritable(1);%0A%09%0A%09@Override%0A%09public void map(Object key, Text value, Context context) throws IOException, InterruptedException%7B%0A%09%09for (String src : value.toString().split(%22%5C%5Cs+%22))%7B%0A%09%09  item.set(src);%0A%09%09  context.write(item, ONE);%0A%09%09%7D%09%09%0A%09%7D%0A%7D%0A

Create Map_1itemset.java