小编mas*_*thd的帖子

从Kafka上的JSON消息创建Spark Streaming中的Spark DataFrame

我正在Scala中实现Spark Streaming,我从Kafka主题中提取JSON字符串,并希望将它们加载到数据帧中.有没有办法做到这一点,Spark从RDD [String]中推断出自己的架构?

scala dataframe apache-kafka apache-spark

8
推荐指数
1
解决办法
6511
查看次数

标签 统计

apache-kafka ×1

apache-spark ×1

dataframe ×1

scala ×1