Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/21477#discussion_r193294262
--- 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 --
I don't think there's a easy way to reference doc across other languages.
It's unfortunate but usually we have duplicated the docs between other language
API docs ...
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
