小编Sli*_*AIZ的帖子

引导服务器与kafka中的zookeeper?

为什么不推荐在kafka-consumer中使用zookeeper以及为什么建议使用bootstrap服务器呢?bootstrap-server的优点是什么?

apache-kafka apache-zookeeper

19
推荐指数
2
解决办法
8448
查看次数

如何将RDD [GenericRecord]转换为scala中的dataframe?

我从Avaf(序列化器和反序列化器)获得了kafka主题的推文.然后我创建了一个Spark消费者,它在RDD [GenericRecord]的Dstream中提取推文.现在我想将每个rdd转换为数据帧,以通过SQL分析这些推文.有什么解决方案可以将RDD [GenericRecord]转换为数据帧吗?

scala avro apache-spark spark-dataframe

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