Using pageRank algorithm to analyze twitter user, implementation based on hadoop streaming
The whole workflow is very similar to http://salsahpc.indiana.edu/csci-b649-spring-2014/projects/project3.html
The original dataset is at http://socialcomputing.asu.edu/datasets/Twitter
1 2
1 3
2 3
2 4
3 4
3 5
- Run job1.sh
- Run gen_iter_value.py
- Run job2.sh
- Run combine_then_update_iter_val.py. If output value(sum of value difference) is greater than the threshold, goes to step 3. If the output value is smaller than threshold, goes to step 5.
- Run sort.py
[4, 0.19241600000000003]
[3, 0.18625066666666665]
[5, 0.16974933333333334]
[2, 0.163584]
[0, 0.14400000000000002]
[1, 0.14400000000000002]
User/Node 4 ranks 1, with the value of 0.192
User/Node 3 ranks 2, with the value of 0.186...
Add a shell script to run everything, I know I'm a slacker so I'll leave it for now ╮(╯_╰)╭