Skip to content

Commit b58765c

Browse files
gatorsmileyhuai
authored andcommitted
[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.
1 parent 835a79d commit b58765c

File tree

1 file changed

+0
-22
lines changed

1 file changed

+0
-22
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/ExistingRDD.scala

Lines changed: 0 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -110,25 +110,3 @@ private[sql] object PhysicalRDD {
110110
PhysicalRDD(output, rdd, relation.toString, relation.isInstanceOf[HadoopFsRelation])
111111
}
112112
}
113-
114-
/** Logical plan node for scanning data from a local collection. */
115-
private[sql]
116-
case class LogicalLocalTable(output: Seq[Attribute], rows: Seq[InternalRow])(sqlContext: SQLContext)
117-
extends LogicalPlan with MultiInstanceRelation {
118-
119-
override def children: Seq[LogicalPlan] = Nil
120-
121-
override def newInstance(): this.type =
122-
LogicalLocalTable(output.map(_.newInstance()), rows)(sqlContext).asInstanceOf[this.type]
123-
124-
override def sameResult(plan: LogicalPlan): Boolean = plan match {
125-
case LogicalRDD(_, otherRDD) => rows == rows
126-
case _ => false
127-
}
128-
129-
@transient override lazy val statistics: Statistics = Statistics(
130-
// TODO: Improve the statistics estimation.
131-
// This is made small enough so it can be broadcasted.
132-
sizeInBytes = sqlContext.conf.autoBroadcastJoinThreshold - 1
133-
)
134-
}

0 commit comments

Comments
 (0)