We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f75f633 commit 7f37d21Copy full SHA for 7f37d21
sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala
@@ -941,10 +941,10 @@ class DataFrame private[sql](
941
/////////////////////////////////////////////////////////////////////////////
942
943
/**
944
- * Returns the content of the [[DataFrame]] as an [[RDD]] of [[Row]]s.
+ * Represents the content of the [[DataFrame]] as an [[RDD]] of [[Row]]s.
945
* @group rdd
946
*/
947
- def rdd: RDD[Row] = {
+ lazy val rdd: RDD[Row] = {
948
// use a local variable to make sure the map closure doesn't capture the whole DataFrame
949
val schema = this.schema
950
queryExecution.executedPlan.execute().map(ScalaReflection.convertRowToScala(_, schema))
0 commit comments