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: [email protected]
