diff options
author | gatorsmile <gatorsmile@gmail.com> | 2015-11-15 21:10:46 -0800 |
---|---|---|
committer | Yin Huai <yhuai@databricks.com> | 2015-11-15 21:10:46 -0800 |
commit | b58765caa6d7e6933050565c5d423c45e7e70ba6 (patch) | |
tree | ffcd300d3a3da35b7a1ac4921bce3c3b15f89926 | |
parent | 835a79d78ee879a3c36dde85e5b3591243bf3957 (diff) | |
download | spark-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.
-rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/execution/ExistingRDD.scala | 22 |
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 - ) -} |