Github user joseph-torres commented on a diff in the pull request:
https://github.com/apache/spark/pull/18973#discussion_r138114144
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicLogicalOperators.scala
---
@@ -443,7 +444,8 @@ case class Range(
end: Long,
step: Long,
numSlices: Option[Int],
- output: Seq[Attribute])
+ output: Seq[Attribute],
+ override val isStreaming: Boolean)
--- End diff --
I don't think there's necessarily a reason it shouldn't be able to;
streaming sources are free to define getBatch() however they'd like.
Right now the only source actually doing that is a fake source in
StreamSuite.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
