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