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 5b47901 commit 1d41bb5Copy full SHA for 1d41bb5
sql/core/src/main/scala/org/apache/spark/sql/json/JSONRelation.scala
@@ -25,7 +25,7 @@ private[sql] class DefaultSource extends RelationProvider {
25
override def createRelation(
26
sqlContext: SQLContext,
27
parameters: Map[String, String]): BaseRelation = {
28
- val fileName = parameters.getOrElse("fileName", sys.error("Option 'fileName' not specified"))
+ val fileName = parameters.getOrElse("path", sys.error("Option 'path' not specified"))
29
val samplingRatio = parameters.get("samplingRatio").map(_.toDouble).getOrElse(1.0)
30
31
JSONRelation(fileName, samplingRatio)(sqlContext)
0 commit comments