@@ -0,0 +1,719 @@
+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.Reducer;%0Aimport org.apache.hadoop.mapreduce.Reducer.Context;%0A%0Apublic class Reduce extends Reducer%3CText, IntWritable, Text, IntWritable%3E %7B%0A%09@Override%0A%09public void reduce(Text key, Iterable%3CIntWritable%3E values, Context context) throws IOException, InterruptedException %7B%0A%09%09int countItemFreq = 0;%0A%09%09%0A%09%09for (IntWritable value : values)%7B%0A%09%09%09countItemFreq += value.get();%0A%09%09%7D%0A%09%09%0A%09%09int minsup = Integer.parseInt(context.getConfiguration().get(%22minsup%22));%0A%09%09%0A%09%09if (countItemFreq %3E= minsup)%0A%09%09%7B%0A%09%09%09context.write(key, new IntWritable(countItemFreq));%0A%09%09%7D%0A%09%7D%0A%7D%0A

Create Reduce.java