modified spacing

core/src/main/java/org/apache/spark/api/shuffle/ShuffleDataIO.java

@@ -27,5 +27,5 @@
  */
 @Experimental
 public interface ShuffleDataIO {
-    ShuffleExecutorComponents executor();
+  ShuffleExecutorComponents executor();
 }

core/src/main/java/org/apache/spark/api/shuffle/ShuffleExecutorComponents.java

@@ -27,8 +27,7 @@
  */
 @Experimental
 public interface ShuffleExecutorComponents {
+  void intitializeExecutor(String appId, String execId);
 
-    void intitializeExecutor(String appId, String execId);
-
-    ShuffleWriteSupport writes();
+  ShuffleWriteSupport writes();
 }

core/src/main/java/org/apache/spark/api/shuffle/ShuffleMapOutputWriter.java

@@ -29,10 +29,9 @@
  */
 @Experimental
 public interface ShuffleMapOutputWriter {
+  ShufflePartitionWriter getNextPartitionWriter() throws IOException;
 
-    ShufflePartitionWriter getNextPartitionWriter() throws IOException;
+  void commitAllPartitions() throws IOException;
 
-    void commitAllPartitions() throws IOException;
-
-    void abort(Throwable error) throws IOException;
+  void abort(Throwable error) throws IOException;
 }

core/src/main/java/org/apache/spark/api/shuffle/ShufflePartitionWriter.java

@@ -32,12 +32,11 @@
  */
 @Experimental
 public interface ShufflePartitionWriter {
+  OutputStream openStream() throws IOException;
 
-    OutputStream openStream() throws IOException;
+  long getLength();
 
-    long getLength();
-
-    default WritableByteChannel openChannel() throws IOException {
-        return Channels.newChannel(openStream());
-    }
+  default WritableByteChannel openChannel() throws IOException {
+    return Channels.newChannel(openStream());
+  }
 }

core/src/main/java/org/apache/spark/api/shuffle/ShuffleWriteSupport.java

@@ -29,10 +29,9 @@
  */
 @Experimental
 public interface ShuffleWriteSupport {
-
-   ShuffleMapOutputWriter createMapOutputWriter(
-       String appId,
-       int shuffleId,
-       int mapId,
-       int numPartitions) throws IOException;
+  ShuffleMapOutputWriter createMapOutputWriter(
+    String appId,
+    int shuffleId,
+    int mapId,
+    int numPartitions) throws IOException;
 }