wangshuo128 commented on a change in pull request #31968:
URL: https://github.com/apache/spark/pull/31968#discussion_r607461493
##########
File path:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/LocalRelation.scala
##########
@@ -49,11 +49,13 @@ object LocalRelation {
*
* @param data The local collection holding the data. It doesn't need to be
sent to executors
* and then doesn't need to be serializable.
+ * @param fromCommand Indicates whether the relation data is result of
[[Command]]
+ * @param isStreaming Indicates whether this relation has data from a
streaming source
*/
case class LocalRelation(
output: Seq[Attribute],
data: Seq[InternalRow] = Nil,
- // Indicates whether this relation has data from a streaming source.
+ fromCommand: Boolean = false,
Review comment:
Ok, will fix it.
I thought we should put the override members at the end.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
