我有一个JavaDStream,它从外部源获取数据.我正在尝试集成Spark Streaming和SparkSQL.众所周知,JavaDStream是由JavaRDD组成的.我只能在拥有JavaRDD时应用函数applySchema().请帮我转换为JavaRDD.我知道scala中有函数,它更容易.但是用Java帮助我.
java apache-spark apache-spark-sql
apache-spark ×1
apache-spark-sql ×1
java ×1