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: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org