Skip to content

Commit ec64554

Browse files
committed
address comments
1 parent db21531 commit ec64554

File tree

3 files changed

+0
-6
lines changed

3 files changed

+0
-6
lines changed

sql/core/src/main/java/org/apache/spark/sql/sources/v2/ContinuousReadSupport.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,8 +20,6 @@
2020
import java.util.Optional;
2121

2222
import org.apache.spark.annotation.InterfaceStability;
23-
import org.apache.spark.sql.sources.v2.DataSourceV2;
24-
import org.apache.spark.sql.sources.v2.DataSourceOptions;
2523
import org.apache.spark.sql.sources.v2.reader.streaming.ContinuousReader;
2624
import org.apache.spark.sql.types.StructType;
2725

sql/core/src/main/java/org/apache/spark/sql/sources/v2/MicroBatchReadSupport.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,8 +20,6 @@
2020
import java.util.Optional;
2121

2222
import org.apache.spark.annotation.InterfaceStability;
23-
import org.apache.spark.sql.sources.v2.DataSourceOptions;
24-
import org.apache.spark.sql.sources.v2.DataSourceV2;
2523
import org.apache.spark.sql.sources.v2.reader.streaming.MicroBatchReader;
2624
import org.apache.spark.sql.types.StructType;
2725

sql/core/src/main/java/org/apache/spark/sql/sources/v2/StreamWriteSupport.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,8 +19,6 @@
1919

2020
import org.apache.spark.annotation.InterfaceStability;
2121
import org.apache.spark.sql.execution.streaming.BaseStreamingSink;
22-
import org.apache.spark.sql.sources.v2.DataSourceOptions;
23-
import org.apache.spark.sql.sources.v2.DataSourceV2;
2422
import org.apache.spark.sql.sources.v2.writer.DataSourceWriter;
2523
import org.apache.spark.sql.sources.v2.writer.streaming.StreamWriter;
2624
import org.apache.spark.sql.streaming.OutputMode;

0 commit comments

Comments
 (0)