Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/20276#discussion_r162431289
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicLogicalOperators.scala
---
@@ -902,9 +902,20 @@ case class Deduplicate(
*
* This analysis barrier will be removed at the end of analysis stage.
*/
-case class AnalysisBarrier(child: LogicalPlan) extends LeafNode {
+case class AnalysisBarrier(child: LogicalPlan, id: Long) extends LeafNode {
override protected def innerChildren: Seq[LogicalPlan] = Seq(child)
override def output: Seq[Attribute] = child.output
override def isStreaming: Boolean = child.isStreaming
override def doCanonicalize(): LogicalPlan = child.canonicalized
+ override protected def stringArgs: Iterator[Any] = Iterator(child)
+}
+
+object AnalysisBarrier {
+ private val curId = new java.util.concurrent.atomic.AtomicLong()
--- End diff --
We need to update the doc of `AnalysisBarrier `
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
