From 3814f4f87f4cb6bddbbb9bcec3dd07d52e99cd8d Mon Sep 17 00:00:00 2001 From: feng Date: Fri, 30 Oct 2015 17:48:42 +0100 Subject: [PATCH] Order inversion 3 --- .idea/workspace.xml | 51 +++++++------------ .../eurecom/dsg/mapreduce/OrderInversion.java | 3 +- 2 files changed, 18 insertions(+), 36 deletions(-) diff --git a/.idea/workspace.xml b/.idea/workspace.xml index 1cd64e4..cccb95a 100644 --- a/.idea/workspace.xml +++ b/.idea/workspace.xml @@ -3,7 +3,7 @@ - + @@ -54,25 +54,11 @@ - - - - - - - - - - - - - - - - + + @@ -137,7 +123,7 @@ @@ -471,7 +457,7 @@ - + @@ -545,7 +531,6 @@ - @@ -623,7 +608,6 @@ - @@ -932,44 +916,43 @@ - - + + - - + - + - - - - - + - + + + + + - - + + diff --git a/src/main/java/fr/eurecom/dsg/mapreduce/OrderInversion.java b/src/main/java/fr/eurecom/dsg/mapreduce/OrderInversion.java index 69c4fa2..ffd776b 100644 --- a/src/main/java/fr/eurecom/dsg/mapreduce/OrderInversion.java +++ b/src/main/java/fr/eurecom/dsg/mapreduce/OrderInversion.java @@ -87,13 +87,12 @@ public class OrderInversion extends Configured implements Tool { for (IntWritable value : values) { totalnumber += value.get(); } - context.write(key, new DoubleWritable(totalnumber)); } else { int count = 0; for (IntWritable value : values) { count += value.get(); } - context.write(key, new DoubleWritable(count / totalnumber)); + context.write(key, new DoubleWritable(count / totalnumber)); } } } -- GitLab