Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/20286#discussion_r161976371
--- Diff:
sql/core/src/main/java/org/apache/spark/sql/sources/v2/streaming/reader/ContinuousReader.java
---
@@ -27,11 +28,15 @@
* interface to allow reading in a continuous processing mode stream.
*
* Implementations must ensure each read task output is a {@link
ContinuousDataReader}.
+ *
+ * Note: This class currently extends {@link BaseStreamingSource} to
maintain compatibility with
+ * DataSource V1 APIs. This will be extension will be removed once we get
rid of V1 completely.
--- End diff --
nit: This ~~will be~~ extension
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
