Skip to content

Commit b74f4d5

Browse files
committed
[SPARK-25727][FOLLOWUP] Move outputOrdering to case class field for InMemoryRelation
1 parent 9426fd0 commit b74f4d5

File tree

1 file changed

+15
-15
lines changed

1 file changed

+15
-15
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/InMemoryRelation.scala

Lines changed: 15 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -149,30 +149,30 @@ object InMemoryRelation {
149149
tableName: Option[String],
150150
logicalPlan: LogicalPlan): InMemoryRelation = {
151151
val cacheBuilder = CachedRDDBuilder(useCompression, batchSize, storageLevel, child, tableName)()
152-
new InMemoryRelation(child.output, cacheBuilder)(
153-
statsOfPlanToCache = logicalPlan.stats, outputOrdering = logicalPlan.outputOrdering)
152+
new InMemoryRelation(child.output, cacheBuilder, logicalPlan.outputOrdering)(
153+
statsOfPlanToCache = logicalPlan.stats)
154154
}
155155

156156
def apply(cacheBuilder: CachedRDDBuilder, logicalPlan: LogicalPlan): InMemoryRelation = {
157-
new InMemoryRelation(cacheBuilder.cachedPlan.output, cacheBuilder)(
158-
statsOfPlanToCache = logicalPlan.stats, outputOrdering = logicalPlan.outputOrdering)
157+
new InMemoryRelation(cacheBuilder.cachedPlan.output, cacheBuilder, logicalPlan.outputOrdering)(
158+
statsOfPlanToCache = logicalPlan.stats)
159159
}
160160
}
161161

162162
case class InMemoryRelation(
163163
output: Seq[Attribute],
164-
@transient cacheBuilder: CachedRDDBuilder)(
165-
statsOfPlanToCache: Statistics,
166-
override val outputOrdering: Seq[SortOrder])
164+
@transient cacheBuilder: CachedRDDBuilder,
165+
override val outputOrdering: Seq[SortOrder])(
166+
statsOfPlanToCache: Statistics)
167167
extends logical.LeafNode with MultiInstanceRelation {
168168

169169
override protected def innerChildren: Seq[SparkPlan] = Seq(cachedPlan)
170170

171171
override def doCanonicalize(): logical.LogicalPlan =
172172
copy(output = output.map(QueryPlan.normalizeExprId(_, cachedPlan.output)),
173-
cacheBuilder)(
174-
statsOfPlanToCache,
175-
outputOrdering)
173+
cacheBuilder,
174+
outputOrdering)(
175+
statsOfPlanToCache)
176176

177177
override def producedAttributes: AttributeSet = outputSet
178178

@@ -195,18 +195,18 @@ case class InMemoryRelation(
195195
}
196196

197197
def withOutput(newOutput: Seq[Attribute]): InMemoryRelation = {
198-
InMemoryRelation(newOutput, cacheBuilder)(statsOfPlanToCache, outputOrdering)
198+
InMemoryRelation(newOutput, cacheBuilder, outputOrdering)(statsOfPlanToCache)
199199
}
200200

201201
override def newInstance(): this.type = {
202202
new InMemoryRelation(
203203
output.map(_.newInstance()),
204-
cacheBuilder)(
205-
statsOfPlanToCache,
206-
outputOrdering).asInstanceOf[this.type]
204+
cacheBuilder,
205+
outputOrdering)(
206+
statsOfPlanToCache).asInstanceOf[this.type]
207207
}
208208

209-
override protected def otherCopyArgs: Seq[AnyRef] = Seq(statsOfPlanToCache, outputOrdering)
209+
override protected def otherCopyArgs: Seq[AnyRef] = Seq(statsOfPlanToCache)
210210

211211
override def simpleString: String =
212212
s"InMemoryRelation [${Utils.truncatedString(output, ", ")}], ${cacheBuilder.storageLevel}"

0 commit comments

Comments
 (0)