Skip to content

Commit 3cf5479

Browse files
committed
remove override in StreamWriter - incompatible with SupportsWriteInternalRow
1 parent c6d4ff5 commit 3cf5479

File tree

1 file changed

+0
-8
lines changed
  • sql/core/src/main/java/org/apache/spark/sql/sources/v2/writer/streaming

1 file changed

+0
-8
lines changed

sql/core/src/main/java/org/apache/spark/sql/sources/v2/writer/streaming/StreamWriter.java

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -63,14 +63,6 @@ public interface StreamWriter extends DataSourceWriter {
6363
*/
6464
void abort(long epochId, WriterCommitMessage[] messages);
6565

66-
/**
67-
* Creates a writer factory which will be serialized and sent to executors.
68-
*
69-
* If this method fails (by throwing an exception), the query will fail and no Spark job will be
70-
* submitted.
71-
*/
72-
StreamingDataWriterFactory<Row> createWriterFactory();
73-
7466
default void commit(WriterCommitMessage[] messages) {
7567
throw new UnsupportedOperationException(
7668
"Commit without epoch should not be called with StreamWriter");

0 commit comments

Comments
 (0)