File tree Expand file tree Collapse file tree 1 file changed +0
-20
lines changed
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical Expand file tree Collapse file tree 1 file changed +0
-20
lines changed Original file line number Diff line number Diff line change @@ -924,23 +924,3 @@ case class Deduplicate(
924924
925925 override def output : Seq [Attribute ] = child.output
926926}
927-
928- /**
929- * A logical plan for setting a barrier of analysis.
930- *
931- * The SQL Analyzer goes through a whole query plan even most part of it is analyzed. This
932- * increases the time spent on query analysis for long pipelines in ML, especially.
933- *
934- * This logical plan wraps an analyzed logical plan to prevent it from analysis again. The barrier
935- * is applied to the analyzed logical plan in Dataset. It won't change the output of wrapped
936- * logical plan and just acts as a wrapper to hide it from analyzer. New operations on the dataset
937- * will be put on the barrier, so only the new nodes created will be analyzed.
938- *
939- * This analysis barrier will be removed at the end of analysis stage.
940- */
941- case class AnalysisBarrier (child : LogicalPlan ) extends LeafNode {
942- override protected def innerChildren : Seq [LogicalPlan ] = Seq (child)
943- override def output : Seq [Attribute ] = child.output
944- override def isStreaming : Boolean = child.isStreaming
945- override def doCanonicalize (): LogicalPlan = child.canonicalized
946- }
You can’t perform that action at this time.
0 commit comments