26-SparkStreaming02

用户行为日志

信令数据

cell

mapWithState

DStream 整合RDD == transform

数据一：日志信息    DStream

domain,traffic

ruozedata.com

ruozedata.com

baidu.com

数据二：已有的文件  黑名单  RDD

domain

baidu.com

==> 

(ruozedata.com, ruozedata.com,8888)

www.ruozedata.com,8888

www.ruozedata.com,6666

www.baidu.com,7777

www.yy.com 

test.yy.com 

create table wc(

word varchar(20),

c int(10)

) 

zidong,zidong,i,love,you,ymy,say

bonecp

word count time

ruoze 10    201809092130

ruoze 9    201809092131

upsert