Examples of org.apache.hadoop.hdfs.DeprecatedUTF8

org.apache.hadoop.hdfs.DeprecatedUTF8
A simple wrapper around {@link org.apache.hadoop.io.UTF8}. This class should be used only when it is absolutely necessary to use {@link org.apache.hadoop.io.UTF8}. The only difference is that using this class does not require "@SuppressWarning" annotation to avoid javac warning. Instead the deprecation is implied in the class name. This should be treated as package private class to HDFS.

      return this;
    }


    @Override 
    void writeFields(DataOutputStream out) throws IOException {
      new DeprecatedUTF8(src).write(out);
      permissions.write(out);
     }

View Full Code Here

      return this;
    }


    @Override 
    void writeFields(DataOutputStream out) throws IOException {
      DeprecatedUTF8 u = new DeprecatedUTF8(username == null? "": username);
      DeprecatedUTF8 g = new DeprecatedUTF8(groupname == null? "": groupname);
      new DeprecatedUTF8(src).write(out);
      u.write(out);
      g.write(out);
    }

View Full Code Here

      return this;
    }


    @Override 
    void writeFields(DataOutputStream out) throws IOException {
      new DeprecatedUTF8(src).write(out);
      new LongWritable(nsQuota).write(out);
      new LongWritable(dsQuota).write(out);
    }

View Full Code Here

  // This should be reverted to package private once the ImageLoader
  // code is moved into this package. This method should not be called
  // by other code.
  @SuppressWarnings("deprecation")
  public static String readString(DataInputStream in) throws IOException {
    DeprecatedUTF8 ustr = TL_DATA.get().U_STR;
    ustr.readFields(in);
    return ustr.toString();
  }

View Full Code Here

    return s.isEmpty()? null: s;
  }


  @SuppressWarnings("deprecation")
  static void writeString(String str, DataOutputStream out) throws IOException {
    DeprecatedUTF8 ustr = TL_DATA.get().U_STR;
    ustr.set(str);
    ustr.write(out);
  }

View Full Code Here




  // Same comments apply for this method as for readString()
  @SuppressWarnings("deprecation")
  public static byte[] readBytes(DataInputStream in) throws IOException {
    DeprecatedUTF8 ustr = TL_DATA.get().U_STR;
    ustr.readFields(in);
    int len = ustr.getLength();
    byte[] bytes = new byte[len];
    System.arraycopy(ustr.getBytes(), 0, bytes, 0, len);
    return bytes;
  }

View Full Code Here

   * @throws IOException
   */
  @SuppressWarnings("deprecation")
  public static byte[][] readPathComponents(DataInputStream in)
      throws IOException {
    DeprecatedUTF8 ustr = TL_DATA.get().U_STR;
    
    ustr.readFields(in);
    return DFSUtil.bytes2byteArray(ustr.getBytes(),
      ustr.getLength(), (byte) Path.SEPARATOR_CHAR);
  }

View Full Code Here

   * Add open lease record to edit log. 
   * Records the block locations of the last block.
   */
  public void logOpenFile(String path, INodeFileUnderConstruction newNode) {


    DeprecatedUTF8 nameReplicationPair[] = new DeprecatedUTF8[] { 
      new DeprecatedUTF8(path), 
      FSEditLog.toLogReplication(newNode.getReplication()),
      FSEditLog.toLogLong(newNode.getModificationTime()),
      FSEditLog.toLogLong(newNode.getAccessTime()),
      FSEditLog.toLogLong(newNode.getPreferredBlockSize())};
    logEdit(Ops.OP_ADD,
            new ArrayWritable(DeprecatedUTF8.class, nameReplicationPair), 
            new ArrayWritable(Block.class, newNode.getBlocks()),
            newNode.getPermissionStatus(),
            new DeprecatedUTF8(newNode.getClientName()),
            new DeprecatedUTF8(newNode.getClientMachine()));
  }

View Full Code Here


  /** 
   * Add close lease record to edit log.
   */
  public void logCloseFile(String path, INodeFile newNode) {
    DeprecatedUTF8 nameReplicationPair[] = new DeprecatedUTF8[] {
      new DeprecatedUTF8(path),
      FSEditLog.toLogReplication(newNode.getReplication()),
      FSEditLog.toLogLong(newNode.getModificationTime()),
      FSEditLog.toLogLong(newNode.getAccessTime()),
      FSEditLog.toLogLong(newNode.getPreferredBlockSize())};
    logEdit(Ops.OP_CLOSE,

View Full Code Here

  
  /** 
   * Add create directory record to edit log
   */
  public void logMkDir(String path, INode newNode) {
    DeprecatedUTF8 info[] = new DeprecatedUTF8[] {
      new DeprecatedUTF8(path),
      FSEditLog.toLogLong(newNode.getModificationTime()),
      FSEditLog.toLogLong(newNode.getAccessTime())
    };
    logEdit(Ops.OP_MKDIR, new ArrayWritable(DeprecatedUTF8.class, info),
        newNode.getPermissionStatus());

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of org.apache.hadoop.hdfs.DeprecatedUTF8

org.apache.hadoop.hdfs.server.namenode.FSEditLog

org.apache.hadoop.hdfs.server.namenode.FSEditLogOp

org.apache.hadoop.hdfs.server.namenode.FSEditLogOp$AddCloseOp

org.apache.hadoop.hdfs.server.namenode.FSEditLogOp$ConcatDeleteOp

org.apache.hadoop.hdfs.server.namenode.FSEditLogOp$DeleteOp

org.apache.hadoop.hdfs.server.namenode.FSEditLogOp$MkdirOp

org.apache.hadoop.hdfs.server.namenode.FSEditLogOp$ReassignLeaseOp

org.apache.hadoop.hdfs.server.namenode.FSEditLogOp$RenameOldOp

org.apache.hadoop.hdfs.server.namenode.FSEditLogOp$RenameOp

org.apache.hadoop.hdfs.server.namenode.FSEditLogOp$SetOwnerOp

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.