UpdateStateByKey

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

慕运维7479159

2018-02-02

老师，上网搜索了大量的资料，只有 word count 统计，而请问，如果统计一个ip的操作流程怎么办，

UpdateStateByKey 算子应该可以解决这个问题，

现在我需要上一个操作与下一个操作进行对比，不仅仅是数量的相加，除了key值之外，使用对象的另一个属性进行对比，请问这个需求如何实现，希望老师给予指导

写回答

1回答

Michael_PK

2018-02-02

不太明白你的需求。update操作仅适用于中间状态的累积

Spark Streaming实时流处理项目实战

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

1404 学习 · 571 问题

相似问题

回答 1

回答 1

回答 1

回答 1

回答 1