Skip to content

Commit 50a13b3

Browse files
author
Wenqi Li
committed
delete AsyncUtil
1 parent 428c52d commit 50a13b3

File tree

1 file changed

+2
-3
lines changed
  • hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router

1 file changed

+2
-3
lines changed

hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterAsyncSnapshot.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,6 @@
2727
import org.apache.hadoop.hdfs.server.federation.resolver.FederationNamespaceInfo;
2828
import org.apache.hadoop.hdfs.server.federation.resolver.RemoteLocation;
2929
import org.apache.hadoop.hdfs.server.federation.router.async.ApplyFunction;
30-
import org.apache.hadoop.hdfs.server.federation.router.async.AsyncUtil;
3130
import org.apache.hadoop.hdfs.server.namenode.NameNode;
3231

3332
import java.io.IOException;
@@ -87,7 +86,7 @@ public String createSnapshot(String snapshotRoot, String snapshotName) throws IO
8786
return invokedResult.replaceFirst(loc.getDest(), loc.getSrc());
8887
});
8988
}
90-
return AsyncUtil.asyncReturn(String.class);
89+
return asyncReturn(String.class);
9190
}
9291

9392
@Override
@@ -101,7 +100,7 @@ public SnapshottableDirectoryStatus[] getSnapshottableDirListing() throws IOExce
101100
asyncApply((ApplyFunction<Map<FederationNamespaceInfo, SnapshottableDirectoryStatus[]>,
102101
SnapshottableDirectoryStatus[]>)
103102
ret -> RouterRpcServer.merge(ret, SnapshottableDirectoryStatus.class));
104-
return AsyncUtil.asyncReturn(SnapshottableDirectoryStatus[].class);
103+
return asyncReturn(SnapshottableDirectoryStatus[].class);
105104
}
106105

107106
@Override

0 commit comments

Comments
 (0)