Addressed comments

apache · Jan 17, 2018 · 3b3029b · 3b3029b
1 parent f6dfa58
commit 3b3029b
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/...core/src/main/java/org/apache/spark/sql/sources/v2/streaming/reader/ContinuousReader.java b/...core/src/main/java/org/apache/spark/sql/sources/v2/streaming/reader/ContinuousReader.java
@@ -30,7 +30,7 @@
  * 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.
+ * DataSource V1 APIs. This extension will be removed once we get rid of V1 completely.
  */
 @InterfaceStability.Evolving
 public interface ContinuousReader extends BaseStreamingSource, DataSourceV2Reader {

diff --git a/...core/src/main/java/org/apache/spark/sql/sources/v2/streaming/reader/MicroBatchReader.java b/...core/src/main/java/org/apache/spark/sql/sources/v2/streaming/reader/MicroBatchReader.java
@@ -28,7 +28,7 @@
  * interface to indicate they allow micro-batch streaming reads.
  *
  * 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.
+ * DataSource V1 APIs. This extension will be removed once we get rid of V1 completely.
  */
 @InterfaceStability.Evolving
 public interface MicroBatchReader extends DataSourceV2Reader, BaseStreamingSource {

diff --git a/sql/core/src/main/java/org/apache/spark/sql/sources/v2/streaming/reader/Offset.java b/sql/core/src/main/java/org/apache/spark/sql/sources/v2/streaming/reader/Offset.java
@@ -27,7 +27,7 @@
  * to reconstruct a position in the stream up to which data has been seen/processed.
  *
  * Note: This class currently extends {@link org.apache.spark.sql.execution.streaming.Offset} to
- * maintain compatibility with DataSource V1 APIs. This will be extension will be removed once we
+ * maintain compatibility with DataSource V1 APIs. This extension will be removed once we
  * get rid of V1 completely.
  */
 @InterfaceStability.Evolving