File tree Expand file tree Collapse file tree 1 file changed +1
-3
lines changed
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources Expand file tree Collapse file tree 1 file changed +1
-3
lines changed Original file line number Diff line number Diff line change @@ -416,8 +416,7 @@ case class DataSource(
416416 /**
417417 * Writes the given [[DataFrame ]] out to this [[DataSource ]].
418418 *
419- * @param isForWriteOnly Whether to exit early and just write the data without returning
420- * a [[BaseRelation ]].
419+ * @param isForWriteOnly Whether to just write the data without returning a [[BaseRelation ]].
421420 */
422421 def write (
423422 mode : SaveMode ,
@@ -501,7 +500,6 @@ case class DataSource(
501500 fileIndex = fileIndex)
502501 sparkSession.sessionState.executePlan(plan).toRdd
503502 if (isForWriteOnly) {
504- // Exit earlier and return null
505503 None
506504 } else {
507505 // Replace the schema with that of the DataFrame we just wrote out to avoid re-inferring
You can’t perform that action at this time.
0 commit comments