@Test public void tryOne() throws IOException, InterruptedException { Text inKey=new Text("qr"); Iterable<VIntWritable> inValues=new RecyclingIterable( VIntWritable.class, new VIntWritable(76412), new VIntWritable(2), new VIntWritable(7) ); reducer.reduce(inKey,inValues,context); Text outKey=new Text("1951-06 qr"); Text outValue=new Text("3 76421"); verify(context).write(outKey,outValue); }
@Override protected void reduce(Text key, Iterable<VIntWritable> values, Context context) throws IOException, InterruptedException { int uriCount=0; long viewCount=0; for(VIntWritable views:values) { uriCount++; viewCount+=views.get(); } Text outKey=new Text(yrmo+" "+key.toString()); Text outValue=new Text(uriCount+" "+viewCount); context.write(outKey,outValue); }
NormalizeMonthliesReducer extends Reducer<Text,VIntWritable,Text,Text> { @Override protected void reduce(Text key, Iterable<VIntWritable> values, Context context) throws IOException, InterruptedException { int uriCount=0; long viewCount=0; for(VIntWritable views:values) { uriCount++; viewCount+=views.get(); } Text outKey=new Text(yrmo+" "+key.toString()); Text outValue=new Text(uriCount+" "+viewCount); context.write(outKey,outValue); } }
NormalizeMonthliesReducer extends Reducer<Text,VIntWritable,Text,Text> { @Override protected void reduce(Text key, Iterable<VIntWritable> values, Context context) throws IOException, InterruptedException { int uriCount=0; long viewCount=0; for(VIntWritable views:values) { uriCount++; viewCount+=views.get(); } Text outKey=new Text(yrmo+" "+key.toString()); Text outValue=new Text(uriCount+" "+viewCount); context.write(outKey,outValue); }  }
NormalizeMonthliesReducer extends Reducer<Text,VIntWritable,Text,Text> { @Override protected void reduce(Text key, Iterable<VIntWritable> values, Context context) throws IOException, InterruptedException { int uriCount=0; long viewCount=0; for(VIntWritable views:values) { uriCount++; viewCount+=views.get(); } Text outKey=new Text(yrmo+" "+key.toString()); Text outValue=new Text(uriCount+" "+viewCount); context.write(outKey,outValue); }   }
NormalizeMonthliesReducer extends Reducer<Text,VIntWritable,Text,Text> { @Override protected void reduce(Text key, Iterable<VIntWritable> values, Context context) throws IOException, InterruptedException { int uriCount=0; long viewCount=0; for(VIntWritable views:values) { uriCount++; viewCount+=views.get(); } Text outKey=new Text(yrmo+" "+key.toString()); Text outValue=new Text(uriCount+" "+viewCount); context.write(outKey,outValue); }   final static public String YRMO; }