Examples of org.apache.hadoop.util.DataChecksum.writeValue()

Class org.apache.hadoop.util.DataChecksum

Examples of org.apache.hadoop.util.DataChecksum.writeValue()

org.apache.hadoop.util.DataChecksum.writeValue()
Writes the current checksum to the stream. If reset is true, then resets the checksum. @return number of bytes written. Will be equal to getChecksumSize();

      blockRAF.close();
    }


    //compute checksum
    dcs.update(b, 0, lastchunksize);
    dcs.writeValue(b, 0, false);


    //update metaFile
    RandomAccessFile metaRAF = new RandomAccessFile(metaFile, "rw");
    try {
      metaRAF.setLength(newmetalen);

View Full Code Here

      int bytesRead = dataStream.read(buf, bytesSinceFlush, 
          bytesPerChecksum - bytesSinceFlush);
      if (bytesRead == -1) {
        if (bytesSinceFlush > 0) {
          boolean reset = true;
          sum.writeValue(chk, 0, reset); // This also resets the sum.
          // Write the checksum to the stream.
          mdOut.write(chk, 0, chk.length);
          bytesSinceFlush = 0;
        }
        break;

View Full Code Here

      bytesSinceFlush += bytesRead;


      // Flush the checksum if necessary.
      if (bytesSinceFlush == bytesPerChecksum) {
        boolean reset = true;
        sum.writeValue(chk, 0, reset); // This also resets the sum.
        // Write the checksum to the stream.
        mdOut.write(chk, 0, chk.length);
        bytesSinceFlush = 0;
      }
    }

View Full Code Here

      ra.close();
    }


    // compute checksum
    dcs.update(b, 0, lastchunksize);
    dcs.writeValue(b, 0, false);


    // update metaFile
    RandomAccessFile metaRAF = new RandomAccessFile(metafile, "rw");
    try {
      metaRAF.setLength(newmetalen);

View Full Code Here

        ra.seek(lastchunkoffset);
        ra.readFully(b, 0, lastchunksize);


        // compute checksum
        dcs.update(b, 0, lastchunksize);
        dcs.writeValue(b, 0, false);


        ra.seek(newBlockFileSize - checksumSize);
        ra.write(b, 0, checksumSize);
      }
    } finally {

View Full Code Here

0 1 2 3 4

TOP

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.