你可以查看Spark Streaming和sqlnetworkWordCount,这些内容解释了通过使用SparkStreaming的SparkContext创建SparkSession的singleton instance可以解决你的问题。通过阅读上述链接,你应该能够更好地理解如何从streaming rdd创建dataframes。
InputStream
是什么? - Reactormonk