Examples of java.io.DataOutput

java.io.DataOutput
The DataOutput interface provides for converting data from any of the Java primitive types to a series of bytes and writing these bytes to a binary stream. There is also a facility for converting a String into modified UTF-8 format and writing the resulting series of bytes.
For all the methods in this interface that write bytes, it is generally true that if a byte cannot be written for any reason, an IOException is thrown. @author Frank Yellin @version 1.23, 05/23/06 @see java.io.DataInput @see java.io.DataOutputStream @since JDK1.0


      // write the root level
      long rootLevelIndexPos = out.getPos();


      {
        DataOutput blockStream =
            blockWriter.startWriting(BlockType.ROOT_INDEX);
        rootChunk.writeRoot(blockStream);
        if (midKeyMetadata != null)
          blockStream.write(midKeyMetadata);
        blockWriter.writeHeaderAndData(out);
      }


      // Add root index block size
      totalBlockOnDiskSize += blockWriter.getOnDiskSizeWithoutHeader();

View Full Code Here

   */
  void serialize(DataOutputStream outputStream) throws IOException {
    HFile.checkFormatVersion(majorVersion);


    ByteArrayOutputStream baos = new ByteArrayOutputStream();
    DataOutput baosDos = new DataOutputStream(baos);


    BlockType.TRAILER.write(baosDos);
    baosDos.writeLong(fileInfoOffset);
    baosDos.writeLong(loadOnOpenDataOffset);
    baosDos.writeInt(dataIndexCount);


    if (majorVersion == 1) {
      // This used to be metaIndexOffset, but it was not used in version 1.
      baosDos.writeLong(0);
    } else {
      baosDos.writeLong(uncompressedDataIndexSize);
    }


    baosDos.writeInt(metaIndexCount);
    baosDos.writeLong(totalUncompressedBytes);
    if (majorVersion == 1) {
      baosDos.writeInt((int) Math.min(Integer.MAX_VALUE, entryCount));
    } else {
      // This field is long from version 2 onwards.
      baosDos.writeLong(entryCount);
    }
    baosDos.writeInt(compressionCodec.ordinal());


    if (majorVersion > 1) {
      baosDos.writeInt(numDataIndexLevels);
      baosDos.writeLong(firstDataBlockOffset);
      baosDos.writeLong(lastDataBlockOffset);
      Bytes.writeStringFixedSize(baosDos, comparatorClassName,
          MAX_COMPARATOR_NAME_LENGTH);
    }


    // serialize the major and minor versions
    baosDos.writeInt(materializeVersion(majorVersion, minorVersion));


    outputStream.write(baos.toByteArray());
  }

View Full Code Here

                dataOut.writeByte(type);
                bs.marshal(dataOut);
                dsm.tightMarshal2(this, c, dataOut, bs);


            } else {
                DataOutput looseOut = dataOut;


                if (!sizePrefixDisabled) {
                    bytesOut.restart();
                    looseOut = bytesOut;
                }


                looseOut.writeByte(type);
                dsm.looseMarshal(this, c, looseOut);


                if (!sizePrefixDisabled) {
                    ByteSequence sequence = bytesOut.toByteSequence();
                    dataOut.writeInt(sequence.getLength());

View Full Code Here

                dataOut.writeByte(type);
                bs.marshal(dataOut);
                dsm.tightMarshal2(this, c, dataOut, bs);


            } else {
                DataOutput looseOut = dataOut;


                if (!sizePrefixDisabled) {
                    bytesOut.restart();
                    looseOut = bytesOut;
                }


                looseOut.writeByte(type);
                dsm.looseMarshal(this, c, looseOut);


                if (!sizePrefixDisabled) {
                    ByteSequence sequence = bytesOut.toByteSequence();
                    dataOut.writeInt(sequence.getLength());

View Full Code Here

     *            boolean
     */


    public void writeIntArray(int[] array, boolean append) {
        try {
            DataOutput dos;
            if (bigEndian) {
                dos = new DataOutputStream(stream);
            } else {
                dos = new LEDataOutputStream(stream);
            }


            for (int i = 0; i < array.length; i++) {
                dos.writeInt(array[i]);
            }


            stream.close();
        } catch (IOException e) {
            throw new IllegalArgumentException("InputStream is unwritable : "

View Full Code Here

     *            boolean
     */


    public void writeFloatArray(float[] array, boolean append) {
        try {
            DataOutput dos;
            if (bigEndian) {
                dos = new DataOutputStream(stream);
            } else {
                dos = new LEDataOutputStream(stream);
            }


            for (int i = 0; i < array.length; i++) {
                dos.writeFloat(array[i]);
            }


            stream.close();
        } catch (IOException e) {
            throw new IllegalArgumentException("InputStream is unwritable : "

View Full Code Here

     *            boolean
     */


    public void writeDoubleArray(double[] array, boolean append) {
        try {
            DataOutput dos;
            if (bigEndian) {
                dos = new DataOutputStream(stream);
            } else {
                dos = new LEDataOutputStream(stream);
            }


            for (int i = 0; i < array.length; i++) {
                dos.writeDouble(array[i]);
            }


            stream.close();
        } catch (IOException e) {
            throw new IllegalArgumentException("InputStream is unwritable : "

View Full Code Here

    }


    public static byte[] writeToByteArray(Writable writableObject) {
        ByteArrayOutputStream outputStream =
            new ByteArrayOutputStream();
        DataOutput output = new DataOutputStream(outputStream);
        try {
            writableObject.write(output);
        } catch (IOException e) {
            throw new IllegalStateException(
                "writeToByteArray: IOStateException", e);

View Full Code Here

    }


    public static byte[] writeListToByteArray(
            List<? extends Writable> writableList) {
        ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
        DataOutput output = new DataOutputStream(outputStream);
        try {
            output.writeInt(writableList.size());
            for (Writable writable : writableList) {
                writable.write(output);
            }
        } catch (IOException e) {
            throw new IllegalStateException(

View Full Code Here

        String inputSplitPath = null;
        for (int i = 0; i< splitList.size(); ++i) {
            try {
                ByteArrayOutputStream byteArrayOutputStream =
                    new ByteArrayOutputStream();
                DataOutput outputStream =
                    new DataOutputStream(byteArrayOutputStream);
                InputSplit inputSplit = splitList.get(i);
                Text.writeString(outputStream,
                                 inputSplit.getClass().getName());
                ((Writable) inputSplit).write(outputStream);

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of java.io.DataOutput

com.clearspring.analytics.stream.cardinality.HyperLogLog

com.cloudera.flume.handlers.batch.BatchingDecorator

com.cloudera.flume.handlers.hdfs.WriteableEvent

com.facebook.collections.PackedByteArray

com.facebook.giraph.hive.common.Writables

com.facebook.hiveio.common.Writables

com.salesforce.phoenix.index.IndexMaintainer

com.sun.jini.discovery.internal.Plaintext

com.xuggle.xuggler.io.DataInputOutputHandler

org.apache.activeio.journal.active.LogFileManager

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.