Java: Data Science Made Easy

Writing the reduce method

Next, we will write our AverageReduce class. This class extends the Reducer class and will perform the reduction processes to calculate our average page count. We have created four variables for this class: a FloatWritable object to store our average page count, a float average to hold our temporary average, a float count to count how many books exist in our dataset, and an integer sum to add up the page counts:

public static class AverageReduce         extends Reducer<Text, IntWritable, Text, FloatWritable> {     private final FloatWritable finalAvg = new FloatWritable();     Float average = 0f;     Float count = 0f;     int sum = 0; } 

Within our AverageReduce class we will create the reduce method. This method takes as input a ...