itemSet
HBase
topic2
slopeOne
spark streaming
api
ainsight
parsefiltertransform
Single-threaded timing reads
UserCF
INPUT
redis
ALG
Mysql
reduceByKeygroupByKeyflatMap
useritemscore
itemidScoreDiffuserCount
topic1
kafka
predictsort
DStream
spark rdd
OUTPUT
ETL
spark core
