File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
sql/core/src/main/scala/org/apache/spark/sql/parquet Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -373,10 +373,10 @@ private[parquet] object ParquetTypesConverter extends Logging {
373373 }
374374 ParquetRelation .enableLogForwarding()
375375
376- val children = fs.listStatus(path).filterNot(
377- status => ( status.getPath.getName.charAt( 0 ) == '.' ||
378- status.getPath.getName == FileOutputCommitter .SUCCEEDED_FILE_NAME )
379- )
376+ val children = fs.listStatus(path).filterNot { status =>
377+ val name = status.getPath.getName
378+ name( 0 ) == '.' || name == FileOutputCommitter .SUCCEEDED_FILE_NAME
379+ }
380380
381381 // NOTE (lian): Parquet "_metadata" file can be very slow if the file consists of lots of row
382382 // groups. Since Parquet schema is replicated among all row groups, we only need to touch a
You can’t perform that action at this time.
0 commit comments