spark整合kafka

DStream转为DF的两种方式（突破map时元组22的限制）

在进行Spark Streaming的开发时，我们常常需要将DStream转为DataFrame来进行进一步的 […]

利用mapWithState实现按照首字母统计的有状态的wordCount

最近在做sparkstreaming整合kafka的时候遇到了一个问题：可以抽象成这样一个问题：有状态的wo […]