aboutsummaryrefslogtreecommitdiff
path: root/sql/catalyst
diff options
context:
space:
mode:
Diffstat (limited to 'sql/catalyst')
-rw-r--r--sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala8
1 files changed, 5 insertions, 3 deletions
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala
index 14b03c7445..00bdf108a8 100644
--- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala
+++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala
@@ -114,11 +114,13 @@ case class InsertIntoTable(
}
}
-case class CreateTableAsSelect(
+case class CreateTableAsSelect[T](
databaseName: Option[String],
tableName: String,
- child: LogicalPlan) extends UnaryNode {
- override def output = child.output
+ child: LogicalPlan,
+ allowExisting: Boolean,
+ desc: Option[T] = None) extends UnaryNode {
+ override def output = Seq.empty[Attribute]
override lazy val resolved = (databaseName != None && childrenResolved)
}