File tree Expand file tree Collapse file tree 1 file changed +1
-2
lines changed
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/csv Expand file tree Collapse file tree 1 file changed +1
-2
lines changed Original file line number Diff line number Diff line change @@ -53,7 +53,7 @@ class CSVFileFormat extends TextBasedFileFormat with DataSourceRegister {
5353 val csvOptions = new CSVOptions (options)
5454
5555 // TODO: Move filtering.
56- val paths = files.filterNot(_.getPath.getName. startsWith( " _" ) ).map(_.getPath.toString)
56+ val paths = files.filterNot(_.getPath.getName startsWith " _" ).map(_.getPath.toString)
5757 val rdd = baseRdd(sparkSession, csvOptions, paths)
5858 val firstLine = findFirstLine(csvOptions, rdd)
5959 val firstRow = new CsvReader (csvOptions).parseLine(firstLine)
@@ -76,7 +76,6 @@ class CSVFileFormat extends TextBasedFileFormat with DataSourceRegister {
7676 }
7777 StructType (schemaFields)
7878 }
79-
8079 Some (schema)
8180 }
8281
You can’t perform that action at this time.
0 commit comments