关于map转换的疑问

来源:8-5 -实战之黑名单过滤

KelvinChung

2020-03-08

图片描述
问题一:请问老师为什么会出现这个结果呢,我输入的是123,aaa;进入map,x.split(",")(1),就是用逗号分隔后的第一个应该是123,然后后面的x就是传进来的一条数据应该是(123,aaa),我感觉输出来的应该是(123,123,aaa)这样的呀,请问老师我哪里理解错了呢?
问题二:我上面的代码是想测试一下老师黑名单的功能,在需求上写的是:20180808,zs ==>(zs:20180808,zs),为什么第一个是冒号不是逗号呢,,?

写回答

1回答

Michael_PK

2020-03-08

1)我明白你的意思,建议你走个debug,观察每一步的输出,就明确知道处理后的结果是什么了

2)第二个问题,你贴下代码,我记不太清了,我记得是把进来的数据,把要join的key抽取出来的

0
8
Michael_PK
回复
KelvinChung
还是那句话,你走一个debug跟踪,每个步骤的数据都看的清清楚楚
2020-03-09
共8条回复

Spark Streaming实时流处理项目实战

Flume+Kafka+Spark Streaming 构建通用实时流处理平台

1404 学习 · 571 问题

查看课程