Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/spark/pull/21477#discussion_r193304316
--- Diff: sql/core/src/main/scala/org/apache/spark/sql/ForeachWriter.scala
---
@@ -20,10 +20,48 @@ package org.apache.spark.sql
import org.apache.spark.annotation.InterfaceStability
/**
- * A class to consume data generated by a `StreamingQuery`. Typically this
is used to send the
- * generated data to external systems. Each partition will use a new
deserialized instance, so you
- * usually should do all the initialization (e.g. opening a connection or
initiating a transaction)
- * in the `open` method.
+ * The abstract class for writing custom logic to process data generated
by a query.
+ * This is often used to write the output of a streaming query to
arbitrary storage systems.
--- End diff --
Ah yes my bad. I confused this as python.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
