HDFS-12885. Add visibility/stability annotations. Contributed by Chris Douglas
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/63a2e7cf Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/63a2e7cf Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/63a2e7cf Branch: refs/heads/HDFS-9806 Commit: 63a2e7cf36100cc0b9fb31c572e40b7511bfa286 Parents: c7bbd01 Author: Virajith Jalaparti <[email protected]> Authored: Tue Dec 5 09:51:09 2017 -0800 Committer: Virajith Jalaparti <[email protected]> Committed: Fri Dec 15 10:18:29 2017 -0800 ---------------------------------------------------------------------- .../apache/hadoop/hdfs/protocol/ProvidedStorageLocation.java | 4 ++++ .../org/apache/hadoop/hdfs/protocolPB/AliasMapProtocolPB.java | 2 ++ .../hdfs/protocolPB/AliasMapProtocolServerSideTranslatorPB.java | 4 ++++ .../InMemoryAliasMapProtocolClientSideTranslatorPB.java | 4 ++++ .../apache/hadoop/hdfs/server/aliasmap/InMemoryAliasMap.java | 4 ++++ .../hadoop/hdfs/server/aliasmap/InMemoryAliasMapProtocol.java | 4 ++++ .../hdfs/server/aliasmap/InMemoryLevelDBAliasMapServer.java | 4 ++++ .../hadoop/hdfs/server/blockmanagement/ProvidedStorageMap.java | 4 ++++ .../java/org/apache/hadoop/hdfs/server/common/BlockAlias.java | 4 ++++ .../java/org/apache/hadoop/hdfs/server/common/FileRegion.java | 4 ++++ .../hadoop/hdfs/server/common/blockaliasmap/BlockAliasMap.java | 4 ++++ .../blockaliasmap/impl/InMemoryLevelDBAliasMapClient.java | 4 ++++ .../common/blockaliasmap/impl/LevelDBFileRegionAliasMap.java | 4 ++++ .../common/blockaliasmap/impl/TextFileRegionAliasMap.java | 4 ++++ .../hadoop/hdfs/server/datanode/FinalizedProvidedReplica.java | 4 ++++ .../org/apache/hadoop/hdfs/server/datanode/ProvidedReplica.java | 4 ++++ .../hdfs/server/datanode/fsdataset/impl/ProvidedVolumeImpl.java | 4 +++- .../org/apache/hadoop/hdfs/server/namenode/BlockResolver.java | 4 ++++ .../java/org/apache/hadoop/hdfs/server/namenode/FSTreeWalk.java | 4 ++++ .../org/apache/hadoop/hdfs/server/namenode/FileSystemImage.java | 4 ++++ .../hdfs/server/namenode/FixedBlockMultiReplicaResolver.java | 4 ++++ .../apache/hadoop/hdfs/server/namenode/FixedBlockResolver.java | 4 ++++ .../org/apache/hadoop/hdfs/server/namenode/FsUGIResolver.java | 5 +++++ .../org/apache/hadoop/hdfs/server/namenode/ImageWriter.java | 4 ++++ .../apache/hadoop/hdfs/server/namenode/NullBlockAliasMap.java | 4 ++++ .../apache/hadoop/hdfs/server/namenode/SingleUGIResolver.java | 4 ++++ .../java/org/apache/hadoop/hdfs/server/namenode/TreePath.java | 4 ++++ .../java/org/apache/hadoop/hdfs/server/namenode/TreeWalk.java | 5 +++++ .../org/apache/hadoop/hdfs/server/namenode/UGIResolver.java | 4 ++++ .../org/apache/hadoop/hdfs/server/namenode/RandomTreeWalk.java | 4 ++++ 30 files changed, 119 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/protocol/ProvidedStorageLocation.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/protocol/ProvidedStorageLocation.java b/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/protocol/ProvidedStorageLocation.java index eee58ba..861ef8e 100644 --- a/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/protocol/ProvidedStorageLocation.java +++ b/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/protocol/ProvidedStorageLocation.java @@ -16,6 +16,8 @@ */ package org.apache.hadoop.hdfs.protocol; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.fs.Path; import javax.annotation.Nonnull; @@ -25,6 +27,8 @@ import java.util.Arrays; * ProvidedStorageLocation is a location in an external storage system * containing the data for a block (~Replica). */ [email protected] [email protected] public class ProvidedStorageLocation { private final Path path; private final long offset; http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocolPB/AliasMapProtocolPB.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocolPB/AliasMapProtocolPB.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocolPB/AliasMapProtocolPB.java index 98b3ee1..4e14fad 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocolPB/AliasMapProtocolPB.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocolPB/AliasMapProtocolPB.java @@ -17,6 +17,7 @@ package org.apache.hadoop.hdfs.protocolPB; import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.hdfs.protocol.proto.AliasMapProtocolProtos; import org.apache.hadoop.ipc.ProtocolInfo; @@ -30,6 +31,7 @@ import org.apache.hadoop.ipc.ProtocolInfo; "org.apache.hadoop.hdfs.server.aliasmap.AliasMapProtocol", protocolVersion = 1) @InterfaceAudience.Private [email protected] public interface AliasMapProtocolPB extends AliasMapProtocolProtos.AliasMapProtocolService.BlockingInterface { } http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocolPB/AliasMapProtocolServerSideTranslatorPB.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocolPB/AliasMapProtocolServerSideTranslatorPB.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocolPB/AliasMapProtocolServerSideTranslatorPB.java index 808c43b..15a1124 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocolPB/AliasMapProtocolServerSideTranslatorPB.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocolPB/AliasMapProtocolServerSideTranslatorPB.java @@ -18,6 +18,8 @@ package org.apache.hadoop.hdfs.protocolPB; import com.google.protobuf.RpcController; import com.google.protobuf.ServiceException; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.hdfs.protocol.Block; import org.apache.hadoop.hdfs.protocol.ProvidedStorageLocation; import org.apache.hadoop.hdfs.protocol.proto.AliasMapProtocolProtos.KeyValueProto; @@ -40,6 +42,8 @@ import static org.apache.hadoop.hdfs.server.aliasmap.InMemoryAliasMap.*; * AliasMapProtocolServerSideTranslatorPB is responsible for translating RPC * calls and forwarding them to the internal InMemoryAliasMap. */ [email protected] [email protected] public class AliasMapProtocolServerSideTranslatorPB implements AliasMapProtocolPB { http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocolPB/InMemoryAliasMapProtocolClientSideTranslatorPB.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocolPB/InMemoryAliasMapProtocolClientSideTranslatorPB.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocolPB/InMemoryAliasMapProtocolClientSideTranslatorPB.java index a79360f..7f6cc91 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocolPB/InMemoryAliasMapProtocolClientSideTranslatorPB.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocolPB/InMemoryAliasMapProtocolClientSideTranslatorPB.java @@ -17,6 +17,8 @@ package org.apache.hadoop.hdfs.protocolPB; import com.google.protobuf.ServiceException; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hdfs.protocol.Block; import org.apache.hadoop.hdfs.protocol.ProvidedStorageLocation; @@ -47,6 +49,8 @@ import static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.*; * {@link InMemoryAliasMapProtocol} interface to the RPC server implementing * {@link AliasMapProtocolPB}. */ [email protected] [email protected] public class InMemoryAliasMapProtocolClientSideTranslatorPB implements InMemoryAliasMapProtocol { http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/aliasmap/InMemoryAliasMap.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/aliasmap/InMemoryAliasMap.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/aliasmap/InMemoryAliasMap.java index be891e5..f7be111 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/aliasmap/InMemoryAliasMap.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/aliasmap/InMemoryAliasMap.java @@ -19,6 +19,8 @@ package org.apache.hadoop.hdfs.server.aliasmap; import com.google.common.annotations.VisibleForTesting; import com.google.common.collect.Lists; import com.google.protobuf.InvalidProtocolBufferException; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configurable; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hdfs.DFSConfigKeys; @@ -47,6 +49,8 @@ import java.util.Optional; * InMemoryAliasMap is an implementation of the InMemoryAliasMapProtocol for * use with LevelDB. */ [email protected] [email protected] public class InMemoryAliasMap implements InMemoryAliasMapProtocol, Configurable { http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/aliasmap/InMemoryAliasMapProtocol.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/aliasmap/InMemoryAliasMapProtocol.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/aliasmap/InMemoryAliasMapProtocol.java index fb6e8b3..c89c6b6 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/aliasmap/InMemoryAliasMapProtocol.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/aliasmap/InMemoryAliasMapProtocol.java @@ -16,6 +16,8 @@ */ package org.apache.hadoop.hdfs.server.aliasmap; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.hdfs.protocol.Block; import org.apache.hadoop.hdfs.protocol.ProvidedStorageLocation; import org.apache.hadoop.hdfs.server.common.FileRegion; @@ -30,6 +32,8 @@ import java.util.Optional; * provided blocks for an in-memory implementation of the * {@link org.apache.hadoop.hdfs.server.common.blockaliasmap.BlockAliasMap}. */ [email protected] [email protected] public interface InMemoryAliasMapProtocol { /** http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/aliasmap/InMemoryLevelDBAliasMapServer.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/aliasmap/InMemoryLevelDBAliasMapServer.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/aliasmap/InMemoryLevelDBAliasMapServer.java index 91b1e83..197e663 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/aliasmap/InMemoryLevelDBAliasMapServer.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/aliasmap/InMemoryLevelDBAliasMapServer.java @@ -17,6 +17,8 @@ package org.apache.hadoop.hdfs.server.aliasmap; import com.google.protobuf.BlockingService; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.ipc.ProtobufRpcEngine; import org.apache.hadoop.security.UserGroupInformation; import org.slf4j.Logger; @@ -42,6 +44,8 @@ import static org.apache.hadoop.hdfs.server.aliasmap.InMemoryAliasMap.CheckedFun * InMemoryLevelDBAliasMapServer is the entry point from the Namenode into * the {@link InMemoryAliasMap}. */ [email protected] [email protected] public class InMemoryLevelDBAliasMapServer implements InMemoryAliasMapProtocol, Configurable, Closeable { http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/ProvidedStorageMap.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/ProvidedStorageMap.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/ProvidedStorageMap.java index c85eb2c..f6b0c0b 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/ProvidedStorageMap.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/ProvidedStorageMap.java @@ -30,6 +30,8 @@ import java.util.UUID; import java.util.concurrent.ConcurrentSkipListMap; import com.google.common.annotations.VisibleForTesting; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.StorageType; import org.apache.hadoop.hdfs.DFSConfigKeys; @@ -57,6 +59,8 @@ import com.google.protobuf.ByteString; * This class allows us to manage and multiplex between storages local to * datanodes, and provided storage. */ [email protected] [email protected] public class ProvidedStorageMap { private static final Logger LOG = http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/BlockAlias.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/BlockAlias.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/BlockAlias.java index b2fac97..316953f 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/BlockAlias.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/BlockAlias.java @@ -17,11 +17,15 @@ */ package org.apache.hadoop.hdfs.server.common; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.hdfs.protocol.Block; /** * Interface used to load provided blocks. */ [email protected] [email protected] public interface BlockAlias { Block getBlock(); http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/FileRegion.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/FileRegion.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/FileRegion.java index 5d04640..c2697c8 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/FileRegion.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/FileRegion.java @@ -18,6 +18,8 @@ package org.apache.hadoop.hdfs.server.common; import org.apache.commons.lang3.tuple.Pair; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.fs.Path; import org.apache.hadoop.hdfs.protocol.Block; import org.apache.hadoop.hdfs.protocol.HdfsConstants; @@ -27,6 +29,8 @@ import org.apache.hadoop.hdfs.protocol.ProvidedStorageLocation; * This class is used to represent provided blocks that are file regions, * i.e., can be described using (path, offset, length). */ [email protected] [email protected] public class FileRegion implements BlockAlias { private final Pair<Block, ProvidedStorageLocation> pair; http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/blockaliasmap/BlockAliasMap.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/blockaliasmap/BlockAliasMap.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/blockaliasmap/BlockAliasMap.java index e3b6cb5..8233fbe 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/blockaliasmap/BlockAliasMap.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/blockaliasmap/BlockAliasMap.java @@ -22,12 +22,16 @@ import java.io.IOException; import java.util.Iterator; import java.util.Optional; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.hdfs.protocol.Block; import org.apache.hadoop.hdfs.server.common.BlockAlias; /** * An abstract class used to read and write block maps for provided blocks. */ [email protected] [email protected] public abstract class BlockAliasMap<T extends BlockAlias> { /** http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/blockaliasmap/impl/InMemoryLevelDBAliasMapClient.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/blockaliasmap/impl/InMemoryLevelDBAliasMapClient.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/blockaliasmap/impl/InMemoryLevelDBAliasMapClient.java index 7b0b789..bd6ebd1 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/blockaliasmap/impl/InMemoryLevelDBAliasMapClient.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/blockaliasmap/impl/InMemoryLevelDBAliasMapClient.java @@ -16,6 +16,8 @@ */ package org.apache.hadoop.hdfs.server.common.blockaliasmap.impl; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configurable; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hdfs.protocol.Block; @@ -37,6 +39,8 @@ import java.util.Optional; * This is used by the Datanode and fs2img to store and retrieve FileRegions * based on the given Block. */ [email protected] [email protected] public class InMemoryLevelDBAliasMapClient extends BlockAliasMap<FileRegion> implements Configurable { http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/blockaliasmap/impl/LevelDBFileRegionAliasMap.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/blockaliasmap/impl/LevelDBFileRegionAliasMap.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/blockaliasmap/impl/LevelDBFileRegionAliasMap.java index 66971a3..6a3d55c 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/blockaliasmap/impl/LevelDBFileRegionAliasMap.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/blockaliasmap/impl/LevelDBFileRegionAliasMap.java @@ -24,6 +24,8 @@ import java.util.Iterator; import java.util.Map; import java.util.Optional; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.iq80.leveldb.DB; import org.iq80.leveldb.DBIterator; import static org.fusesource.leveldbjni.JniDBFactory.factory; @@ -45,6 +47,8 @@ import org.slf4j.LoggerFactory; /** * A LevelDB based implementation of {@link BlockAliasMap}. */ [email protected] [email protected] public class LevelDBFileRegionAliasMap extends BlockAliasMap<FileRegion> implements Configurable { http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/blockaliasmap/impl/TextFileRegionAliasMap.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/blockaliasmap/impl/TextFileRegionAliasMap.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/blockaliasmap/impl/TextFileRegionAliasMap.java index b86b280..69d9cc1 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/blockaliasmap/impl/TextFileRegionAliasMap.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/blockaliasmap/impl/TextFileRegionAliasMap.java @@ -34,6 +34,8 @@ import java.util.IdentityHashMap; import java.util.NoSuchElementException; import java.util.Optional; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configurable; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.LocalFileSystem; @@ -56,6 +58,8 @@ import com.google.common.annotations.VisibleForTesting; * This class is used for block maps stored as text files, * with a specified delimiter. */ [email protected] [email protected] public class TextFileRegionAliasMap extends BlockAliasMap<FileRegion> implements Configurable { http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/FinalizedProvidedReplica.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/FinalizedProvidedReplica.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/FinalizedProvidedReplica.java index 0fbfc15..43fd234 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/FinalizedProvidedReplica.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/FinalizedProvidedReplica.java @@ -19,6 +19,8 @@ package org.apache.hadoop.hdfs.server.datanode; import java.net.URI; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; @@ -30,6 +32,8 @@ import org.apache.hadoop.hdfs.server.protocol.ReplicaRecoveryInfo; /** * This class is used for provided replicas that are finalized. */ [email protected] [email protected] public class FinalizedProvidedReplica extends ProvidedReplica { public FinalizedProvidedReplica(long blockId, URI fileURI, http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/ProvidedReplica.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/ProvidedReplica.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/ProvidedReplica.java index 8681421..3d20b00 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/ProvidedReplica.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/ProvidedReplica.java @@ -25,6 +25,8 @@ import java.net.URI; import com.google.common.annotations.VisibleForTesting; import org.apache.commons.io.input.BoundedInputStream; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FSDataInputStream; import org.apache.hadoop.fs.FileSystem; @@ -42,6 +44,8 @@ import org.slf4j.LoggerFactory; /** * This abstract class is used as a base class for provided replicas. */ [email protected] [email protected] public abstract class ProvidedReplica extends ReplicaInfo { public static final Logger LOG = http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/ProvidedVolumeImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/ProvidedVolumeImpl.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/ProvidedVolumeImpl.java index 6bbfa91..445b455 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/ProvidedVolumeImpl.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/ProvidedVolumeImpl.java @@ -28,6 +28,7 @@ import java.util.Map.Entry; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.atomic.AtomicLong; +import org.apache.hadoop.classification.InterfaceAudience; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; @@ -65,7 +66,8 @@ import org.apache.hadoop.util.Time; /** * This class is used to create provided volumes. */ -public class ProvidedVolumeImpl extends FsVolumeImpl { [email protected] +class ProvidedVolumeImpl extends FsVolumeImpl { /** * Get a suffix of the full path, excluding the given prefix. http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/BlockResolver.java ---------------------------------------------------------------------- diff --git a/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/BlockResolver.java b/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/BlockResolver.java index 94b92b8..b18b910 100644 --- a/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/BlockResolver.java +++ b/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/BlockResolver.java @@ -20,6 +20,8 @@ package org.apache.hadoop.hdfs.server.namenode; import java.util.ArrayList; import java.util.List; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.fs.FileStatus; import org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.BlockProto; @@ -27,6 +29,8 @@ import org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.BlockProto; * Given an external reference, create a sequence of blocks and associated * metadata. */ [email protected] [email protected] public abstract class BlockResolver { protected BlockProto buildBlock(long blockId, long bytes) { http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSTreeWalk.java ---------------------------------------------------------------------- diff --git a/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSTreeWalk.java b/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSTreeWalk.java index f736112..7d66c64 100644 --- a/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSTreeWalk.java +++ b/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSTreeWalk.java @@ -23,6 +23,8 @@ import java.util.ArrayList; import java.util.Collections; import java.util.ConcurrentModificationException; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FileStatus; import org.apache.hadoop.fs.FileSystem; @@ -31,6 +33,8 @@ import org.apache.hadoop.fs.Path; /** * Traversal of an external FileSystem. */ [email protected] [email protected] public class FSTreeWalk extends TreeWalk { private final Path root; http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/FileSystemImage.java ---------------------------------------------------------------------- diff --git a/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/FileSystemImage.java b/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/FileSystemImage.java index b66c830..4598e9c 100644 --- a/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/FileSystemImage.java +++ b/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/FileSystemImage.java @@ -26,6 +26,8 @@ import org.apache.commons.cli.Option; import org.apache.commons.cli.Options; import org.apache.commons.cli.ParseException; import org.apache.commons.cli.PosixParser; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; @@ -37,6 +39,8 @@ import org.apache.hadoop.util.ToolRunner; /** * Create FSImage from an external namespace. */ [email protected] [email protected] public class FileSystemImage implements Tool { private Configuration conf; http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/FixedBlockMultiReplicaResolver.java ---------------------------------------------------------------------- diff --git a/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/FixedBlockMultiReplicaResolver.java b/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/FixedBlockMultiReplicaResolver.java index 0c8ce6e..42d4848 100644 --- a/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/FixedBlockMultiReplicaResolver.java +++ b/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/FixedBlockMultiReplicaResolver.java @@ -17,6 +17,8 @@ */ package org.apache.hadoop.hdfs.server.namenode; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FileStatus; @@ -24,6 +26,8 @@ import org.apache.hadoop.fs.FileStatus; * Resolver mapping all files to a configurable, uniform blocksize * and replication. */ [email protected] [email protected] public class FixedBlockMultiReplicaResolver extends FixedBlockResolver { public static final String REPLICATION = http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/FixedBlockResolver.java ---------------------------------------------------------------------- diff --git a/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/FixedBlockResolver.java b/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/FixedBlockResolver.java index 4b3a01f..d130f8d 100644 --- a/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/FixedBlockResolver.java +++ b/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/FixedBlockResolver.java @@ -21,6 +21,8 @@ import java.util.ArrayList; import java.util.List; import java.util.concurrent.atomic.AtomicLong; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configurable; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FileStatus; @@ -28,6 +30,8 @@ import org.apache.hadoop.fs.FileStatus; /** * Resolver mapping all files to a configurable, uniform blocksize. */ [email protected] [email protected] public class FixedBlockResolver extends BlockResolver implements Configurable { public static final String BLOCKSIZE = http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/FsUGIResolver.java ---------------------------------------------------------------------- diff --git a/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/FsUGIResolver.java b/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/FsUGIResolver.java index ca16d96..8c61bc2 100644 --- a/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/FsUGIResolver.java +++ b/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/FsUGIResolver.java @@ -17,6 +17,9 @@ */ package org.apache.hadoop.hdfs.server.namenode; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; + import java.util.HashSet; import java.util.Set; @@ -24,6 +27,8 @@ import java.util.Set; * Dynamically assign ids to users/groups as they appear in the external * filesystem. */ [email protected] [email protected] public class FsUGIResolver extends UGIResolver { private int id; http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/ImageWriter.java ---------------------------------------------------------------------- diff --git a/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/ImageWriter.java b/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/ImageWriter.java index 9bd8852..370c683 100644 --- a/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/ImageWriter.java +++ b/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/ImageWriter.java @@ -38,6 +38,8 @@ import java.util.concurrent.atomic.AtomicLong; import com.google.common.base.Charsets; import com.google.protobuf.CodedOutputStream; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configurable; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FileSystem; @@ -72,6 +74,8 @@ import static org.apache.hadoop.hdfs.server.namenode.FSImageUtil.MAGIC_HEADER; * a valid FSImage/NN storage. */ // TODO: generalize to types beyond FileRegion [email protected] [email protected] public class ImageWriter implements Closeable { private static final int ONDISK_VERSION = 1; http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/NullBlockAliasMap.java ---------------------------------------------------------------------- diff --git a/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/NullBlockAliasMap.java b/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/NullBlockAliasMap.java index 63d1f27..fcaaf44 100644 --- a/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/NullBlockAliasMap.java +++ b/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/NullBlockAliasMap.java @@ -22,6 +22,8 @@ import java.util.Iterator; import java.util.NoSuchElementException; import java.util.Optional; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.hdfs.protocol.Block; import org.apache.hadoop.hdfs.server.common.FileRegion; import org.apache.hadoop.hdfs.server.common.blockaliasmap.BlockAliasMap; @@ -29,6 +31,8 @@ import org.apache.hadoop.hdfs.server.common.blockaliasmap.BlockAliasMap; /** * Null sink for region information emitted from FSImage. */ [email protected] [email protected] public class NullBlockAliasMap extends BlockAliasMap<FileRegion> { @Override http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/SingleUGIResolver.java ---------------------------------------------------------------------- diff --git a/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/SingleUGIResolver.java b/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/SingleUGIResolver.java index 0fd3f2b..d60806f 100644 --- a/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/SingleUGIResolver.java +++ b/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/SingleUGIResolver.java @@ -19,6 +19,8 @@ package org.apache.hadoop.hdfs.server.namenode; import java.io.IOException; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configurable; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FileStatus; @@ -27,6 +29,8 @@ import org.apache.hadoop.security.UserGroupInformation; /** * Map all owners/groups in external system to a single user in FSImage. */ [email protected] [email protected] public class SingleUGIResolver extends UGIResolver implements Configurable { public static final String UID = "hdfs.image.writer.ugi.single.uid"; http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/TreePath.java ---------------------------------------------------------------------- diff --git a/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/TreePath.java b/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/TreePath.java index d327363..8f1382a 100644 --- a/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/TreePath.java +++ b/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/TreePath.java @@ -21,6 +21,8 @@ import java.io.IOException; import com.google.protobuf.ByteString; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.fs.FileStatus; import org.apache.hadoop.hdfs.protocol.HdfsConstants; import org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.BlockProto; @@ -37,6 +39,8 @@ import static org.apache.hadoop.hdfs.server.namenode.DirectoryWithQuotaFeature.D * Traversal cursor in external filesystem. * TODO: generalize, move FS/FileRegion to FSTreePath */ [email protected] [email protected] public class TreePath { private long id = -1; private final long parentId; http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/TreeWalk.java ---------------------------------------------------------------------- diff --git a/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/TreeWalk.java b/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/TreeWalk.java index 7fd26f9..03675ec 100644 --- a/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/TreeWalk.java +++ b/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/TreeWalk.java @@ -17,6 +17,9 @@ */ package org.apache.hadoop.hdfs.server.namenode; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; + import java.util.ArrayDeque; import java.util.Deque; import java.util.Iterator; @@ -24,6 +27,8 @@ import java.util.Iterator; /** * Traversal yielding a hierarchical sequence of paths. */ [email protected] [email protected] public abstract class TreeWalk implements Iterable<TreePath> { /** http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/UGIResolver.java ---------------------------------------------------------------------- diff --git a/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/UGIResolver.java b/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/UGIResolver.java index 2d50668..72d1fa8 100644 --- a/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/UGIResolver.java +++ b/hadoop-tools/hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode/UGIResolver.java @@ -21,6 +21,8 @@ import java.util.Arrays; import java.util.HashMap; import java.util.Map; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.fs.FileStatus; import org.apache.hadoop.fs.permission.FsPermission; @@ -28,6 +30,8 @@ import org.apache.hadoop.fs.permission.FsPermission; * Pluggable class for mapping ownership and permissions from an external * store to an FSImage. */ [email protected] [email protected] public abstract class UGIResolver { static final int USER_STRID_OFFSET = 40; http://git-wip-us.apache.org/repos/asf/hadoop/blob/63a2e7cf/hadoop-tools/hadoop-fs2img/src/test/java/org/apache/hadoop/hdfs/server/namenode/RandomTreeWalk.java ---------------------------------------------------------------------- diff --git a/hadoop-tools/hadoop-fs2img/src/test/java/org/apache/hadoop/hdfs/server/namenode/RandomTreeWalk.java b/hadoop-tools/hadoop-fs2img/src/test/java/org/apache/hadoop/hdfs/server/namenode/RandomTreeWalk.java index d002e4a..27152fd 100644 --- a/hadoop-tools/hadoop-fs2img/src/test/java/org/apache/hadoop/hdfs/server/namenode/RandomTreeWalk.java +++ b/hadoop-tools/hadoop-fs2img/src/test/java/org/apache/hadoop/hdfs/server/namenode/RandomTreeWalk.java @@ -24,6 +24,8 @@ import java.util.HashMap; import java.util.Map; import java.util.Random; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.fs.BlockLocation; import org.apache.hadoop.fs.FileStatus; import org.apache.hadoop.fs.LocatedFileStatus; @@ -32,6 +34,8 @@ import org.apache.hadoop.fs.Path; /** * Random, repeatable hierarchy generator. */ [email protected] [email protected] public class RandomTreeWalk extends TreeWalk { private final Path root; --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
