Remove assertions which guarded against misplanning.

apache · Feb 4, 2016 · 55e27af · 55e27af
1 parent 924925f
commit 55e27af
Showing 1 changed file with 0 additions and 8 deletions.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/limit.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/limit.scala
@@ -44,14 +44,6 @@ trait BaseLimit extends UnaryNode {
   override def output: Seq[Attribute] = child.output
   override def outputOrdering: Seq[SortOrder] = child.outputOrdering
   override def outputPartitioning: Partitioning = child.outputPartitioning
-  override def executeTake(n: Int): Array[InternalRow] = {
-    throw new UnsupportedOperationException(
-      s"Should not invoke executeTake() on ${getClass.getName}; use CollectLimit instead.")
-  }
-  override def executeCollect(): Array[InternalRow] = {
-    throw new UnsupportedOperationException(
-      s"Should not invoke executeCollect() on ${getClass.getName}; use CollectLimit instead.")
-  }
   protected override def doExecute(): RDD[InternalRow] = child.execute().mapPartitions { iter =>
     iter.take(limit)
   }