有狀態的sparkStreaming

一、mapWithState 案例：是wordCount小程序，單詞word持續增長，由5增長到100了，還會持續增長，由於用到了它的前置數據。必須checkPoint。linux   ssc.checkpoint("hdfs://linux-hadoop01.ibeifeng.com:8020/beifeng/spark/streaming/chkdir45254")小程序 def mappin

>>阅读原文<<