Hadoop源码分析-07-INode

2020-02-10 | 阅读：次

前言

经常使用HDFS,一定听说过文件文件夹修改权限,但是听说过INode的可能不多,如果你对Linux底层比较熟悉的话,可能会了解到Linux存储文件的方式   是采用INode方式存储,HDFS也是仿照Linux底层实现了一套INode元数据文件的存储方式.其中涉及到在开发和使用中不常用的功能,比如XAttr,ACL,快照   等.本文笔者就介绍和简单分析一下HDFS INode结构.

类结构梳理

如下图INode周边类的结构

结构梳理

从上图我们可以看出,整体围绕INode类展开,以INodeAttributes为最底层的接口,其中包含了设置用户,访问时间,ACL,XAttr,修改时间等.

核心类详细解析

INode

INodeAttributes

INodeAttributeProvider

INodeDirectoryAttributes

INodeDirectory

INodeFileAttributes

INodeFile

INodeMap

INodeReference

INodesInPath

INodeWithAdditionalFields

INodeId

INodeSymlink

以下我们一一讲解每个类的用处,以部分类的部分方法的逻辑解析

INode

判断是否是根节点

final boolean isRoot() {
  return getLocalNameBytes().length == 0;
}

设置用户，其中包含了快照版本ID

final INode setUser(String user, int latestSnapshotId) {
  recordModification(latestSnapshotId);
  setUser(user);
  return this;
}

设置权限，这里所指的权限是依据Linux权限

INode setPermission(FsPermission permission, int latestSnapshotId) {
  recordModification(latestSnapshotId);
  setPermission(permission);
  return this;
}

添加XAttr【文件或者文件夹的其他属性】

INode setPermission(FsPermission permission, int latestSnapshotId) {
  recordModification(latestSnapshotId);
  setPermission(permission);
  return this;
}

添加ACL权限，区别于Linux的权限

  abstract void addAclFeature(AclFeature aclFeature);

添加XAttr【文件或者文件夹的其他属性】

  abstract void addXAttrFeature(XAttrFeature xAttrFeature);

   public final boolean isAncestorDirectory(final INodeDirectory dir) {
  for(INodeDirectory p = getParent(); p != null; p = p.getParent()) {
    if (p == dir) {
      return true;
    }
  }
  return false;
}

查看最后修改时间

abstract long getModificationTime(int snapshotId);

INodeAttributes

INodeAttributes部分方法如下:

判断是否是目录

   public boolean isDirectory();

获取权限

  public FsPermission getFsPermission()

INodeAttributeProvider

将路径解析为String数组

  String[] getPathElements(String path) {
  path = path.trim();
  if (path.charAt(0) != Path.SEPARATOR_CHAR) {
    throw new IllegalArgumentException("It must be an absolute path: " +
        path);
  }
  int numOfElements = StringUtils.countMatches(path, Path.SEPARATOR);
  if (path.length() > 1 && path.endsWith(Path.SEPARATOR)) {
    numOfElements--;
  }
  String[] pathElements = new String[numOfElements];
  int elementIdx = 0;
  int idx = 0;
  int found = path.indexOf(Path.SEPARATOR_CHAR, idx);
  while (found > -1) {
    if (found > idx) {
      pathElements[elementIdx++] = path.substring(idx, found);
    }
    idx = found + 1;
    found = path.indexOf(Path.SEPARATOR_CHAR, idx);
  }
  if (idx < path.length()) {
    pathElements[elementIdx] = path.substring(idx);
  }
  return pathElements;
}