实时推荐算法

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