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: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org