Github user cloud-fan commented on a diff in the pull request: https://github.com/apache/spark/pull/20906#discussion_r179685434 --- Diff: sql/core/src/main/java/org/apache/spark/sql/sources/v2/writer/streaming/StreamWriter.java --- @@ -29,14 +31,15 @@ * increasing numeric ID. This writer handles commits and aborts for each successive epoch. */ @InterfaceStability.Evolving -public interface StreamWriter extends DataSourceWriter { --- End diff -- By design we would create more mix-in interfaces for `DataSourceWriter`, like `SupportsWriteColumnarBatch`. If the `StreamWriter` doesn't extend `DataSourceWriter`, how shall we apply those mix-in interfaces for `StreamWriter`?
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org