你的浏览器禁用了JavaScript, 请开启后刷新浏览器获得更好的体验!
没有找到相关结果
regan - run! run! run! happy runner! 我是奔跑的小米~ 2017-02-21 回答
赞同来自:
要回复问题请先登录或注册
苟利国家生死以,岂因祸福避趋之
推荐一份编程学习资源,包含了各类编程语言学习进阶路线图、视频教程、配套书籍文档、数百份面经,各大厂面试真题。编程语言包括:Java、前端、PHP、Python、Linux运维、软件测试、数据解构与算法、C语言、go语言等
微信扫码关注公众号,发送 "编程"获取资源
1 个回复
regan - run! run! run! happy runner! 我是奔跑的小米~ 2017-02-21 回答
赞同来自:
val kafkaStream = KafkaUtils.createDirectStream[String, String]( stream, PreferConsistent, Subscribe[String, String](topics, kafkaParams) ) val results = kafkaStream.map(record => (record.key, record.value)).map(data=>{ val record = data._2 record }).flatMap(data => data.split(" ")).map(data => (data, 1)).reduceByKey(_ + _).updateStateByKey[Int](updateFunction _)
看看官网例子应该能解决