File tree Expand file tree Collapse file tree 2 files changed +1
-8
lines changed
catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical
core/src/main/scala/org/apache/spark/sql Expand file tree Collapse file tree 2 files changed +1
-8
lines changed Original file line number Diff line number Diff line change @@ -186,12 +186,6 @@ case class WithWindowDefinition(
186186 override def output : Seq [Attribute ] = child.output
187187}
188188
189- case class WriteToFile (
190- path : String ,
191- child : LogicalPlan ) extends UnaryNode {
192- override def output : Seq [Attribute ] = child.output
193- }
194-
195189/**
196190 * @param order The ordering expressions
197191 * @param global True means global sorting apply for entire data set,
Original file line number Diff line number Diff line change @@ -139,8 +139,7 @@ class DataFrame private[sql](
139139 // happen right away to let these side effects take place eagerly.
140140 case _ : Command |
141141 _ : InsertIntoTable |
142- _ : CreateTableUsingAsSelect |
143- _ : WriteToFile =>
142+ _ : CreateTableUsingAsSelect =>
144143 LogicalRDD (queryExecution.analyzed.output, queryExecution.toRdd)(sqlContext)
145144 case _ =>
146145 queryExecution.analyzed
You can’t perform that action at this time.
0 commit comments