为什么UpdateStateByKey前面没有加reducebykey呢?

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

为什么UpdateStateByKey前面没有加reducebykey呢?

来源：8-2 -实战之updateStateByKey算子的使用

慕容128306

2019-12-28

写回答

1回答

Michael_PK

Michael_PK

2019-12-28

业务都在update。。。算子里面了呢

0

0

Spark Streaming实时流处理项目实战

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

1404 学习 · 571 问题

相似问题

关于维持一个老用户名单，或者完整黑名单。该用updateStateByKey还是该用redis呢？

回答 1

执行Kafka启动命令后JPS没有出现Kafka

回答 1

PK哥 spark官网上没有2.4.4之前版本的了

回答 3

checkpoint，updateStateByKey

回答 1

消费 Kafka 错误

回答 1

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