Skip to content

Commit ecdd18c

Browse files
committed
Bring back load(path).
1 parent aeaaeb4 commit ecdd18c

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

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

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -114,6 +114,16 @@ class DataFrameReader private[sql](sqlContext: SQLContext) extends Logging {
114114
DataFrame(sqlContext, LogicalRelation(resolved.relation))
115115
}
116116

117+
/**
118+
* Loads input in as a [[DataFrame]], for data sources that require a path (e.g. data backed by
119+
* a local or distributed file system).
120+
*
121+
* @since 1.4.0
122+
*/
123+
def load(path: String): DataFrame = {
124+
option("path", path).load()
125+
}
126+
117127
/**
118128
* Loads input in as a [[DataFrame]], for data sources that support multiple paths.
119129
* Only works if the source is a HadoopFsRelationProvider.

0 commit comments

Comments
 (0)