From 0f0e46ede8ee0db4026330dbe42e3dd2440c152e Mon Sep 17 00:00:00 2001 From: DebugSy <532151398@qq.com> Date: Thu, 11 Jan 2018 13:13:05 +0800 Subject: [PATCH] #5 refactor find common friends --- .../demo/commonfriends/{ => firstStep}/CmFrientsDriver.java | 2 +- .../demo/commonfriends/{ => firstStep}/CmFrientsMapper.java | 2 +- .../demo/commonfriends/{ => firstStep}/CmFrientsReducer.java | 2 +- .../demo/commonfriends/{second => secondStep}/FindDriver.java | 4 +--- .../demo/commonfriends/{second => secondStep}/FindMapper.java | 3 +-- .../commonfriends/{second => secondStep}/FindReducer.java | 2 +- 6 files changed, 6 insertions(+), 9 deletions(-) rename mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/{ => firstStep}/CmFrientsDriver.java (95%) rename mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/{ => firstStep}/CmFrientsMapper.java (94%) rename mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/{ => firstStep}/CmFrientsReducer.java (94%) rename mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/{second => secondStep}/FindDriver.java (87%) rename mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/{second => secondStep}/FindMapper.java (92%) rename mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/{second => secondStep}/FindReducer.java (93%) diff --git a/mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/CmFrientsDriver.java b/mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/firstStep/CmFrientsDriver.java similarity index 95% rename from mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/CmFrientsDriver.java rename to mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/firstStep/CmFrientsDriver.java index f5109e1..9f40f8e 100644 --- a/mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/CmFrientsDriver.java +++ b/mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/firstStep/CmFrientsDriver.java @@ -1,4 +1,4 @@ -package com.mapreduce.demo.commonfriends; +package com.mapreduce.demo.commonfriends.firstStep; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.Path; diff --git a/mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/CmFrientsMapper.java b/mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/firstStep/CmFrientsMapper.java similarity index 94% rename from mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/CmFrientsMapper.java rename to mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/firstStep/CmFrientsMapper.java index 2a684b7..4d52f84 100644 --- a/mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/CmFrientsMapper.java +++ b/mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/firstStep/CmFrientsMapper.java @@ -1,4 +1,4 @@ -package com.mapreduce.demo.commonfriends; +package com.mapreduce.demo.commonfriends.firstStep; import org.apache.hadoop.io.ArrayWritable; import org.apache.hadoop.io.LongWritable; diff --git a/mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/CmFrientsReducer.java b/mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/firstStep/CmFrientsReducer.java similarity index 94% rename from mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/CmFrientsReducer.java rename to mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/firstStep/CmFrientsReducer.java index a101ac8..c6402f4 100644 --- a/mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/CmFrientsReducer.java +++ b/mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/firstStep/CmFrientsReducer.java @@ -1,4 +1,4 @@ -package com.mapreduce.demo.commonfriends; +package com.mapreduce.demo.commonfriends.firstStep; import org.apache.hadoop.io.Text; import org.apache.hadoop.mapreduce.Reducer; diff --git a/mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/second/FindDriver.java b/mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/secondStep/FindDriver.java similarity index 87% rename from mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/second/FindDriver.java rename to mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/secondStep/FindDriver.java index 75862d2..1da1b70 100644 --- a/mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/second/FindDriver.java +++ b/mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/secondStep/FindDriver.java @@ -1,7 +1,5 @@ -package com.mapreduce.demo.commonfriends.second; +package com.mapreduce.demo.commonfriends.secondStep; -import com.mapreduce.demo.commonfriends.CmFrientsMapper; -import com.mapreduce.demo.commonfriends.CmFrientsReducer; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.Path; import org.apache.hadoop.io.Text; diff --git a/mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/second/FindMapper.java b/mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/secondStep/FindMapper.java similarity index 92% rename from mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/second/FindMapper.java rename to mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/secondStep/FindMapper.java index 9e8881e..53bc647 100644 --- a/mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/second/FindMapper.java +++ b/mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/secondStep/FindMapper.java @@ -1,4 +1,4 @@ -package com.mapreduce.demo.commonfriends.second; +package com.mapreduce.demo.commonfriends.secondStep; import org.apache.hadoop.io.LongWritable; import org.apache.hadoop.io.Text; @@ -6,7 +6,6 @@ import java.io.IOException; import java.util.Arrays; -import java.util.Collections; public class FindMapper extends Mapper { diff --git a/mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/second/FindReducer.java b/mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/secondStep/FindReducer.java similarity index 93% rename from mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/second/FindReducer.java rename to mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/secondStep/FindReducer.java index 360469c..422437f 100644 --- a/mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/second/FindReducer.java +++ b/mapreduce-demo/src/main/java/com/mapreduce/demo/commonfriends/secondStep/FindReducer.java @@ -1,4 +1,4 @@ -package com.mapreduce.demo.commonfriends.second; +package com.mapreduce.demo.commonfriends.secondStep; import org.apache.hadoop.io.Text; import org.apache.hadoop.mapreduce.Reducer;