wordCounts.explain() -> query.explain()?
Chang Chen wrote > Hi Guys > > I modified StructuredNetworkWordCount to see what the executed plan is, > here are my codes: > > val wordCounts = words.groupBy("value").count() > > // Start running the query that prints the running counts to the console > val query = wordCounts.writeStream > .outputMode("complete") > .format("console") > .start() > > wordCounts.explain() // additional codes > > > But it failed with “AnalysisException: Queries with streaming sources must > be executed with writeStream.start()”? > > > Thanks > Chang ----- Liang-Chi Hsieh | @viirya Spark Technology Center http://www.spark.tc/ -- Sent from: http://apache-spark-developers-list.1001551.n3.nabble.com/ --------------------------------------------------------------------- To unsubscribe e-mail: dev-unsubscr...@spark.apache.org