Skip to content

Commit

Permalink
Refined SQLContext.emptyResult as an empty RDD[Row]
Browse files Browse the repository at this point in the history
  • Loading branch information
liancheng committed Jun 13, 2014
1 parent cc64f32 commit 48aa2e5
Showing 1 changed file with 1 addition and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -252,8 +252,7 @@ class SQLContext(@transient val sparkContext: SparkContext)
protected[sql] val planner = new SparkPlanner

@transient
protected[sql] lazy val emptyResult =
sparkContext.parallelize(Seq(new GenericRow(Array[Any]()): Row), 1)
protected[sql] lazy val emptyResult = sparkContext.parallelize(Seq.empty[Row], 1)

/**
* Prepares a planned SparkPlan for execution by binding references to specific ordinals, and
Expand Down

0 comments on commit 48aa2e5

Please sign in to comment.