File tree Expand file tree Collapse file tree 1 file changed +10
-10
lines changed
sql/core/src/test/java/test/org/apache/spark/sql/connector Expand file tree Collapse file tree 1 file changed +10
-10
lines changed Original file line number Diff line number Diff line change @@ -70,13 +70,13 @@ public InputPartition[] planInputPartitions() {
7070 FileSystem fs = dataPath .getFileSystem (conf );
7171 if (fs .exists (dataPath )) {
7272 return Arrays .stream (fs .listStatus (dataPath ))
73- .filter (
74- status -> {
75- String name = status .getPath ().getName ();
76- return !name .startsWith ("_" ) && !name .startsWith ("." );
77- })
78- .map (f -> new JavaCSVInputPartitionReader (f .getPath ().toUri ().toString ()))
79- .toArray (InputPartition []::new );
73+ .filter (
74+ status -> {
75+ String name = status .getPath ().getName ();
76+ return !name .startsWith ("_" ) && !name .startsWith ("." );
77+ })
78+ .map (f -> new JavaCSVInputPartitionReader (f .getPath ().toUri ().toString ()))
79+ .toArray (InputPartition []::new );
8080 } else {
8181 return new InputPartition [0 ];
8282 }
@@ -271,9 +271,9 @@ public boolean next() {
271271 @ Override
272272 public InternalRow get () {
273273 Object [] objects =
274- Arrays .stream (currentLine .split ("," ))
275- .map (String ::trim )
276- .map (Integer ::parseInt )
274+ Arrays .stream (currentLine .split ("," ))
275+ .map (String ::trim )
276+ .map (Integer ::parseInt )
277277 .toArray ();
278278 return new GenericInternalRow (objects );
279279 }
You can’t perform that action at this time.
0 commit comments