File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed
core/src/main/scala/org/apache/spark/sql/execution
hive/src/main/scala/org/apache/spark/sql/hive Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -172,11 +172,11 @@ case class UncacheTableCommand(tableName: String) extends RunnableCommand {
172172 */
173173@ DeveloperApi
174174case class DescribeCommand (
175- logicalPlan : LogicalPlan ,
175+ table : LogicalPlan ,
176176 isExtended : Boolean ) extends RunnableCommand {
177177
178178 override def run (sqlContext : SQLContext ) = {
179- val plan = sqlContext.executePlan(logicalPlan ).analyzed
179+ val plan = sqlContext.executePlan(table ).analyzed
180180 plan.output.map(field => Row (field.name, field.dataType.toString, null ))
181181 }
182182
Original file line number Diff line number Diff line change @@ -229,7 +229,7 @@ private[hive] trait HiveStrategies {
229229 ExecutedCommand (
230230 DescribeHiveTableCommand (t, describe.output, describe.isExtended)) :: Nil
231231 case o : LogicalPlan =>
232- ExecutedCommand (RunnableDescribeCommand (planLater(o) , describe.output )) :: Nil
232+ ExecutedCommand (RunnableDescribeCommand (o , describe.isExtended )) :: Nil
233233 }
234234
235235 case _ => Nil
You can’t perform that action at this time.
0 commit comments