#5 refactor find common friends

DebugSy · Jan 11, 2018 · 0f0e46e · 0f0e46e
1 parent 8178d43
commit 0f0e46e
Show file tree

Hide file tree

Showing 6 changed files with 6 additions and 9 deletions.
diff --git a/...e/demo/commonfriends/CmFrientsDriver.java → ...monfriends/firstStep/CmFrientsDriver.java b/...e/demo/commonfriends/CmFrientsDriver.java → ...monfriends/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/...e/demo/commonfriends/CmFrientsMapper.java → ...monfriends/firstStep/CmFrientsMapper.java b/...e/demo/commonfriends/CmFrientsMapper.java → ...monfriends/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/.../demo/commonfriends/CmFrientsReducer.java → ...onfriends/firstStep/CmFrientsReducer.java b/.../demo/commonfriends/CmFrientsReducer.java → ...onfriends/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/...demo/commonfriends/second/FindDriver.java → .../commonfriends/secondStep/FindDriver.java b/...demo/commonfriends/second/FindDriver.java → .../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/...demo/commonfriends/second/FindMapper.java → .../commonfriends/secondStep/FindMapper.java b/...demo/commonfriends/second/FindMapper.java → .../commonfriends/secondStep/FindMapper.java
@@ -1,12 +1,11 @@
-package com.mapreduce.demo.commonfriends.second;
+package com.mapreduce.demo.commonfriends.secondStep;
 
 import org.apache.hadoop.io.LongWritable;
 import org.apache.hadoop.io.Text;
 import org.apache.hadoop.mapreduce.Mapper;
 
 import java.io.IOException;
 import java.util.Arrays;
-import java.util.Collections;
 
 public class FindMapper extends Mapper<LongWritable, Text, Text, Text> {
 

diff --git a/...emo/commonfriends/second/FindReducer.java → ...commonfriends/secondStep/FindReducer.java b/...emo/commonfriends/second/FindReducer.java → ...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;