Skip to content

Commit 32a0fc7

Browse files
committed
backward compatibility
1 parent 4c9549d commit 32a0fc7

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

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

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -381,6 +381,10 @@ object InMemoryRelation {
381381
/* Visible for testing */
382382
private[columnar] def clearSerializer(): Unit = synchronized { ser = None }
383383

384+
def convertToColumnarIfPossible(plan: SparkPlan): SparkPlan = {
385+
getSerializer(plan.conf).convertToColumnarPlanIfPossible(plan)
386+
}
387+
384388
def apply(
385389
storageLevel: StorageLevel,
386390
qe: QueryExecution,

0 commit comments

Comments
 (0)