用戶行為日志
信令數(shù)據(jù)
cell
mapWithState
DStream 整合RDD == transform
數(shù)據(jù)一：日志信息? ? DStream
domain,traffic
ruozedata.com
ruozedata.com
baidu.com
數(shù)據(jù)二：已有的文件? 黑名單? 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
