Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/21029#discussion_r181735802
--- Diff:
sql/core/src/main/java/org/apache/spark/sql/sources/v2/reader/ContinuousDataReaderFactory.java
---
@@ -18,18 +18,26 @@
package
Github user jose-torres commented on a diff in the pull request:
https://github.com/apache/spark/pull/21029#discussion_r180796522
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceV2ScanExec.scala
---
@@ -95,21 +77,29 @@ case class
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/21029#discussion_r180705366
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/memory.scala
---
@@ -143,7 +144,7 @@ case class MemoryStream[A : Encoder](id:
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/21029#discussion_r180705219
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceV2ScanExec.scala
---
@@ -95,21 +77,29 @@ case class
Github user jose-torres commented on a diff in the pull request:
https://github.com/apache/spark/pull/21029#discussion_r180489842
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/memory.scala
---
@@ -143,7 +144,7 @@ case class MemoryStream[A :
Github user jose-torres commented on a diff in the pull request:
https://github.com/apache/spark/pull/21029#discussion_r180489396
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceV2ScanExec.scala
---
@@ -95,21 +77,29 @@ case class
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/21029#discussion_r180468202
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/memory.scala
---
@@ -143,7 +144,7 @@ case class MemoryStream[A : Encoder](id:
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/21029#discussion_r180468097
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/memory.scala
---
@@ -143,7 +144,7 @@ case class MemoryStream[A : Encoder](id:
Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/21029#discussion_r180467422
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceV2ScanExec.scala
---
@@ -95,21 +77,29 @@ case class
