input data | event | mapper1~4 | event | event | output data(merged) | |
---|---|---|---|---|---|---|
file1(Mapper1) | Map | <Hello, 1> <World, 1> <Bye, 1> <World, 1> |
combine | <Hello, 1> <World, 2> <Bye, 1> <World, 1> |
reduce | <Bye, 1> <Goodbye, 1> <Hadoop, 2> <Hello, 2> <World, 2> |
file2(Mapper2) | Map | <Hello, 1> <Hadoop, 1> <Goodbye, 1> <Hadoop, 1> |
combine | <Hello, 1> <Hadoop, 2> <Goodbye, 1> |
reduce |
mvn package wordCount
hadoop jar target/wordCount-1.0-SNAPSHOT.jar WordCountTest src/main/java/input/ src/main/java/output/result