Database Reference
In-Depth Information
dune_avg = rating_sum/count
print("%s\t%f" % ('Dune',dune_avg))
And the job would be run as:
hadoop jar contrib/streaming/hadoop-*streaming*.jar \
-file /home/hduser/mapper.py \
-mapper /home/hduser/movie-mapper.py \
-file /home/hduser/reducer.py \
-reducer /home/hduser/movie-reducer.py \
-input /user/hduser/movie-reviews-in/* \
-output /user/hduser/movie-reviews-out
producing the result:
Dune 5.500000
Mahout
License
Apache License, Version 2.0
Activity
High
Purpose
Machine learning and data analytics
Official Page
Hadoop Integration API Compatible
