在Windows10中运行python代码时出现异常。我使用的是Apache Kafka和PySpark。从Kafka读取数据的Python代码片段 ssc=StreamingContext(sc,60)kvs=KafkaUtils.createStream(KafkaInputDStream.scala:60)
at org.apache.spark.streaming.schedul
我对Scala很陌生,我花了3个小时试图弄清楚如何将一个简单的json字符串解析为dataframe中的一个字符串数组。这是我的密码:import org.apache.spark.sql.functions._emailsDf.select(from_json($"emails", Array[String])).show()
emailsDf dat