Skip to content

Commit 66d5ef1

Browse files
committed
SQLContext minor patch.
1 parent c9bcdc0 commit 66d5ef1

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -454,12 +454,12 @@ class SQLContext(@transient val sparkContext: SparkContext)
454454
@DeveloperApi
455455
protected class QueryExecution(val logical: LogicalPlan) {
456456

457-
lazy val analyzed = ExtractPythonUdfs(analyzer(logical))
458-
lazy val withCachedData = useCachedData(analyzed)
459-
lazy val optimizedPlan = optimizer(withCachedData)
457+
lazy val analyzed: LogicalPlan = ExtractPythonUdfs(analyzer(logical))
458+
lazy val withCachedData: LogicalPlan = useCachedData(analyzed)
459+
lazy val optimizedPlan: LogicalPlan = optimizer(withCachedData)
460460

461461
// TODO: Don't just pick the first one...
462-
lazy val sparkPlan = {
462+
lazy val sparkPlan: SparkPlan = {
463463
SparkPlan.currentContext.set(self)
464464
planner(optimizedPlan).next()
465465
}

0 commit comments

Comments
 (0)