Add ShuffleClient prepareBlocks

biaoma-ty · biaoma-ty · commit 4d9066113e34 · 2016-08-22T22:25:54.000+08:00
diff --git a/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleClient.java b/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleClient.java
@@ -151,4 +151,13 @@ public void registerWithShuffleServer(
   public void close() {
     clientFactory.close();
   }
+
+  @Override
+  public void prepareBlocks(
+      String host,
+      int port,
+      String execId,
+      String[] prepareBlockIds,
+      String[] releaseBlocks,
+      BlockPreparingListener listener) {}
 }
diff --git a/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ShuffleClient.java b/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ShuffleClient.java
@@ -46,10 +46,10 @@ public abstract void fetchBlocks(
    * Prepare a sequence of blocks from remote node asynchronously
    */
   public abstract void prepareBlocks(
-          String host,
-          int port,
-          String execId,
-          String[] prepareBlockIds,
-          String[] releaseBlocks,
-          BlockPreparingListener listener);
+      String host,
+      int port,
+      String execId,
+      String[] prepareBlockIds,
+      String[] releaseBlocks,
+      BlockPreparingListener listener);
 }

Original file line number	Diff line number	Diff line change
`@@ -151,4 +151,13 @@ public void registerWithShuffleServer(`
`151`	`151`	`public void close() {`
`152`	`152`	`clientFactory.close();`
`153`	`153`	`}`
	`154`	`+`
	`155`	`+ @Override`
	`156`	`+ public void prepareBlocks(`
	`157`	`+ String host,`
	`158`	`+ int port,`
	`159`	`+ String execId,`
	`160`	`+ String[] prepareBlockIds,`
	`161`	`+ String[] releaseBlocks,`
	`162`	`+ BlockPreparingListener listener) {}`
`154`	`163`	`}`