aboutsummaryrefslogtreecommitdiff
path: root/sql
diff options
context:
space:
mode:
authorgatorsmile <gatorsmile@gmail.com>2015-11-15 21:10:46 -0800
committerYin Huai <yhuai@databricks.com>2015-11-15 21:10:46 -0800
commitb58765caa6d7e6933050565c5d423c45e7e70ba6 (patch)
treeffcd300d3a3da35b7a1ac4921bce3c3b15f89926 /sql
parent835a79d78ee879a3c36dde85e5b3591243bf3957 (diff)
downloadspark-b58765caa6d7e6933050565c5d423c45e7e70ba6.tar.gz
spark-b58765caa6d7e6933050565c5d423c45e7e70ba6.tar.bz2
spark-b58765caa6d7e6933050565c5d423c45e7e70ba6.zip
[SPARK-9928][SQL] Removal of LogicalLocalTable
LogicalLocalTable in ExistingRDD.scala is replaced by localRelation in LocalRelation.scala? Do you know any reason why we still keep this class? Author: gatorsmile <gatorsmile@gmail.com> Closes #9717 from gatorsmile/LogicalLocalTable.
Diffstat (limited to 'sql')
-rw-r--r--sql/core/src/main/scala/org/apache/spark/sql/execution/ExistingRDD.scala22
1 files changed, 0 insertions, 22 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/ExistingRDD.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/ExistingRDD.scala
index 7a466cf6a0..8b41d3d3d8 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/execution/ExistingRDD.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/ExistingRDD.scala
@@ -110,25 +110,3 @@ private[sql] object PhysicalRDD {
PhysicalRDD(output, rdd, relation.toString, relation.isInstanceOf[HadoopFsRelation])
}
}
-
-/** Logical plan node for scanning data from a local collection. */
-private[sql]
-case class LogicalLocalTable(output: Seq[Attribute], rows: Seq[InternalRow])(sqlContext: SQLContext)
- extends LogicalPlan with MultiInstanceRelation {
-
- override def children: Seq[LogicalPlan] = Nil
-
- override def newInstance(): this.type =
- LogicalLocalTable(output.map(_.newInstance()), rows)(sqlContext).asInstanceOf[this.type]
-
- override def sameResult(plan: LogicalPlan): Boolean = plan match {
- case LogicalRDD(_, otherRDD) => rows == rows
- case _ => false
- }
-
- @transient override lazy val statistics: Statistics = Statistics(
- // TODO: Improve the statistics estimation.
- // This is made small enough so it can be broadcasted.
- sizeInBytes = sqlContext.conf.autoBroadcastJoinThreshold - 1
- )
-}