Skip to content

Commit f5100d6

Browse files
committed
revert
1 parent 9cfd673 commit f5100d6

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

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

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -244,7 +244,7 @@ class DataFrameReader private[sql](sparkSession: SparkSession) extends Logging {
244244
*/
245245
def json(path: String): DataFrame = {
246246
// This method ensures that calls that explicit need single argument works, see SPARK-16009
247-
option("path", path).json(Seq.empty: _*)
247+
json(Seq(path): _*)
248248
}
249249

250250
/**
@@ -337,7 +337,7 @@ class DataFrameReader private[sql](sparkSession: SparkSession) extends Logging {
337337
*/
338338
def csv(path: String): DataFrame = {
339339
// This method ensures that calls that explicit need single argument works, see SPARK-16009
340-
option("path", path).csv(Seq.empty: _*)
340+
csv(Seq(path): _*)
341341
}
342342

343343
/**
@@ -406,7 +406,7 @@ class DataFrameReader private[sql](sparkSession: SparkSession) extends Logging {
406406
*/
407407
def parquet(path: String): DataFrame = {
408408
// This method ensures that calls that explicit need single argument works, see SPARK-16009
409-
option("path", path).parquet(Seq.empty: _*)
409+
parquet(Seq(path): _*)
410410
}
411411

412412
/**
@@ -434,7 +434,7 @@ class DataFrameReader private[sql](sparkSession: SparkSession) extends Logging {
434434
*/
435435
def orc(path: String): DataFrame = {
436436
// This method ensures that calls that explicit need single argument works, see SPARK-16009
437-
option("path", path).orc(Seq.empty: _*)
437+
orc(Seq(path): _*)
438438
}
439439

440440
/**
@@ -467,7 +467,7 @@ class DataFrameReader private[sql](sparkSession: SparkSession) extends Logging {
467467
*/
468468
def text(path: String): DataFrame = {
469469
// This method ensures that calls that explicit need single argument works, see SPARK-16009
470-
option("path", path).text(Seq.empty: _*)
470+
text(Seq(path): _*)
471471
}
472472

473473
/**
@@ -496,7 +496,7 @@ class DataFrameReader private[sql](sparkSession: SparkSession) extends Logging {
496496
*/
497497
def textFile(path: String): Dataset[String] = {
498498
// This method ensures that calls that explicit need single argument works, see SPARK-16009
499-
option("path", path).textFile(Seq.empty: _*)
499+
textFile(Seq(path): _*)
500500
}
501501

502502
/**

0 commit comments

Comments
 (0)