org.apache.hadoop.fs.XAttr#Builder ( )源码实例Demo

下面列出了org.apache.hadoop.fs.XAttr#Builder ( ) 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。

源代码1 项目： hadoop 文件： FSEditLogOp.java

private static List<XAttr> readXAttrsFromXml(Stanza st)
    throws InvalidXmlException {
  if (!st.hasChildren("XATTR")) {
    return null;
  }

  List<Stanza> stanzas = st.getChildren("XATTR");
  List<XAttr> xattrs = Lists.newArrayListWithCapacity(stanzas.size());
  for (Stanza a: stanzas) {
    XAttr.Builder builder = new XAttr.Builder();
    builder.setNameSpace(XAttr.NameSpace.valueOf(a.getValue("NAMESPACE"))).
        setName(a.getValue("NAME"));
    String v = a.getValueOrNull("VALUE");
    if (v != null) {
      try {
        builder.setValue(XAttrCodec.decodeValue(v));
      } catch (IOException e) {
        throw new InvalidXmlException(e.toString());
      }
    }
    xattrs.add(builder.build());
  }
  return xattrs;
}

源代码2 项目： big-c 文件： FSEditLogOp.java

private static List<XAttr> readXAttrsFromXml(Stanza st)
    throws InvalidXmlException {
  if (!st.hasChildren("XATTR")) {
    return null;
  }

  List<Stanza> stanzas = st.getChildren("XATTR");
  List<XAttr> xattrs = Lists.newArrayListWithCapacity(stanzas.size());
  for (Stanza a: stanzas) {
    XAttr.Builder builder = new XAttr.Builder();
    builder.setNameSpace(XAttr.NameSpace.valueOf(a.getValue("NAMESPACE"))).
        setName(a.getValue("NAME"));
    String v = a.getValueOrNull("VALUE");
    if (v != null) {
      try {
        builder.setValue(XAttrCodec.decodeValue(v));
      } catch (IOException e) {
        throw new InvalidXmlException(e.toString());
      }
    }
    xattrs.add(builder.build());
  }
  return xattrs;
}

源代码3 项目： hadoop 文件： PBHelper.java

public static XAttr convertXAttr(XAttrProto a) {
  XAttr.Builder builder = new XAttr.Builder();
  builder.setNameSpace(convert(a.getNamespace()));
  if (a.hasName()) {
    builder.setName(a.getName());
  }
  if (a.hasValue()) {
    builder.setValue(a.getValue().toByteArray());
  }
  return builder.build();
}

源代码4 项目： hadoop 文件： PBHelper.java

public static List<XAttr> convertXAttrs(List<XAttrProto> xAttrSpec) {
  ArrayList<XAttr> xAttrs = Lists.newArrayListWithCapacity(xAttrSpec.size());
  for (XAttrProto a : xAttrSpec) {
    XAttr.Builder builder = new XAttr.Builder();
    builder.setNameSpace(convert(a.getNamespace()));
    if (a.hasName()) {
      builder.setName(a.getName());
    }
    if (a.hasValue()) {
      builder.setValue(a.getValue().toByteArray());
    }
    xAttrs.add(builder.build());
  }
  return xAttrs;
}

源代码5 项目： big-c 文件： PBHelper.java

public static XAttr convertXAttr(XAttrProto a) {
  XAttr.Builder builder = new XAttr.Builder();
  builder.setNameSpace(convert(a.getNamespace()));
  if (a.hasName()) {
    builder.setName(a.getName());
  }
  if (a.hasValue()) {
    builder.setValue(a.getValue().toByteArray());
  }
  return builder.build();
}

源代码6 项目： big-c 文件： PBHelper.java

public static List<XAttr> convertXAttrs(List<XAttrProto> xAttrSpec) {
  ArrayList<XAttr> xAttrs = Lists.newArrayListWithCapacity(xAttrSpec.size());
  for (XAttrProto a : xAttrSpec) {
    XAttr.Builder builder = new XAttr.Builder();
    builder.setNameSpace(convert(a.getNamespace()));
    if (a.hasName()) {
      builder.setName(a.getName());
    }
    if (a.hasValue()) {
      builder.setValue(a.getValue().toByteArray());
    }
    xAttrs.add(builder.build());
  }
  return xAttrs;
}

方法所在类

org.apache.hadoop.fs.XAttr