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

最近在做sparkstreaming整合kafka的时候遇到了一个问题： 可以抽象成这样一个问题：有状态的wordCount，且按照word的第一个字母为key，但是要求输出的格式为(word,1) ...