老师为什么foreachPartition外面定义的数组这个arr 不能存放数据进去呢？

首页课程实战体系课手记专栏慕课教程

老师为什么foreachPartition外面定义的数组这个arr 不能存放数据进去呢？

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

慕函数0552834

2019-10-24

图片描述
老师为什么foreachPartition外面定义的数组这个arr 不能存放数据进去呢？

写回答

1回答

Michael_PK

Michael_PK

2019-10-24

作用域问题。里面就是partition内累加

0

2

Michael_PK

回复

慕函数0552834

这个你可以查阅关于闭包的资料

2019-10-24

共2条回复

Spark Streaming实时流处理项目实战

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

1404 学习 · 571 问题

相似问题

sparkStreaming处理本地文件数据

回答 1

老师我用sparkstreaming读topic数据保存到hdfs上的格式是parquet,但我还要保存他的schema这个改怎样去做

回答 1

关于CourseClickCountDAO中存储数据的疑问

回答 2

老师我有个问题：首先数据到kafka，数据是要全部弄到kafka上，streaming在去处理，还是数据一点一点的到kafka上...

回答 1

为什么大数据的消息订阅发布要选用kafka

回答 1

打开慕课网App查看更多内容