2016-06-07 13:10:41
取消
提交回答
全部回答(1)
-
已采纳sparkStreaming的LoghubUtils.createStream返回的DStream里面都是包含一条条的json日志记录的。
可以用json框架解析的，
请每条记录在原始的日志上多几个字段，请按照业务需求获取。
2 0
大数据计算实践乐园，近距离学习前沿技术
推荐文章
相似问题
- Spark 【问答合集】
- 【精品问答合集】Hbase热门问答
- 阿里官方Java代码规范标准《阿里巴巴Java开发手册》下载
- 【阿里云产品公测】简单日志服务SLS使用评测含教程
- 问几个小白问：服务器重置？数据恢复？及其他？
- java.lang.UnsupportedOperationException: This is supposed to be overridden by subclasses.
- 在flink集群模式下，能不能指定某个节点的solt来执行一个task？
- flink sql 支持checkpoints吗？
- MaxCompute百问集锦（持续更新20171011）
- 速戳 | 20位阿里出题专家-备战阿里必不可少的题目
展开
推荐课程
-
Apache Flink 2021 最新入门课程
学习人数：1591
-
大数据Impala教程
学习人数：54
-
大数据Spark2020最新课程（知识精讲与实战演练）第五阶段
学习人数：146