From 7d6f0ca0bd2e189d200ce0f09d05b41aeb857ad4 Mon Sep 17 00:00:00 2001 From: Ayush Saxena Date: Tue, 13 Apr 2021 23:28:42 +0530 Subject: [PATCH] Revert "HDFS-15884. RBF: Remove unused method getCreateLocation in RouterRpcServer (#2754). Contributed by tomscut." This reverts commit e565b05c80c731898a54f8c1d358c12090ca5bbf. The removed method needs to be used in HDFS-15423. --- .../server/federation/router/RouterRpcServer.java | 14 ++++++++++++++ 1 file changed, 14 insertions(+) diff --git a/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterRpcServer.java b/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterRpcServer.java index 6bf159f7886..1d0800e4bd8 100644 --- a/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterRpcServer.java +++ b/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterRpcServer.java @@ -776,6 +776,20 @@ public HdfsFileStatus create(String src, FsPermission masked, replication, blockSize, supportedVersions, ecPolicyName, storagePolicy); } + + /** + * Get the location to create a file. It checks if the file already existed + * in one of the locations. + * + * @param src Path of the file to check. + * @return The remote location for this file. + * @throws IOException If the file has no creation location. + */ + RemoteLocation getCreateLocation(final String src) throws IOException { + final List locations = getLocationsForPath(src, true); + return getCreateLocation(src, locations); + } + /** * Get the location to create a file. It checks if the file already existed * in one of the locations.