UnsafeByteArrayOutputStream (Apache Giraph Core 1.3.0-SNAPSHOT API)

java.lang.Object
- java.io.OutputStream
- - com.esotericsoftware.kryo.io.Output
  - - org.apache.giraph.utils.UnsafeByteArrayOutputStream

All Implemented Interfaces:

Closeable, DataOutput, Flushable, AutoCloseable, ExtendedDataOutput
```
public class UnsafeByteArrayOutputStream
extends com.esotericsoftware.kryo.io.Output
implements ExtendedDataOutput
```
Byte array output stream that uses Unsafe methods to serialize/deserialize much faster. This stream now extends com.esotericsoftware.kryo.io.Output so that kryo serialization can directly write to this stream without using an additional buffer, providing a faster serialization. Users of this class has to explicitly close the stream to avoid style check errors even though close is no-op when the underlying stream is not set.

Field Summary
- Fields inherited from class com.esotericsoftware.kryo.io.Output
  buffer, capacity, maxCapacity, outputStream, position, total

Constructor Summary

Constructors
Constructor and Description
`UnsafeByteArrayOutputStream()` Constructor
`UnsafeByteArrayOutputStream(byte[] buf)` Constructor to take in a buffer
`UnsafeByteArrayOutputStream(byte[] buf, int pos)` Constructor to take in a buffer with a given position into that buffer
`UnsafeByteArrayOutputStream(int size)` Constructor

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`ensureWritable(int minSize)` Ensure that backing byte structure has at least minSize additional bytes
`byte[]`	`getByteArray()` Get the internal byte array (if possible), read-only
`int`	`getPos()` Get the position in the output stream
`protected boolean`	`require(int size)` Ensure that this buffer has enough remaining space to add the size.
`void`	`reset()` Clears the buffer
`void`	`skipBytes(int bytesToSkip)` Skip some number of bytes.
`byte[]`	`toByteArray()` Copies the internal byte array
`byte[]`	`toByteArray(int offset, int length)` Return a copy of slice of byte array
`void`	`write(byte[] b)`
`void`	`write(byte[] b, int off, int len)`
`void`	`write(int b)`
`void`	`writeBoolean(boolean v)`
`void`	`writeByte(int v)`
`void`	`writeBytes(String s)`
`void`	`writeChar(char v)`
`void`	`writeChar(int v)`
`void`	`writeChars(String s)`
`void`	`writeDouble(double v)`
`void`	`writeFloat(float v)`
`void`	`writeInt(int v)`
`void`	`writeInt(int pos, int value)` In order to write a size as a first part of an data output, it is useful to be able to write an int at an arbitrary location in the stream
`void`	`writeLong(long v)`
`void`	`writeShort(int v)`
`void`	`writeUTF(String s)`

Methods inherited from class com.esotericsoftware.kryo.io.Output
clear, close, flush, getBuffer, getOutputStream, intLength, longLength, position, setBuffer, setBuffer, setOutputStream, setPosition, toBytes, total, writeAscii, writeByte, writeBytes, writeBytes, writeChars, writeDouble, writeDoubles, writeFloat, writeFloats, writeInt, writeInts, writeInts, writeLong, writeLongs, writeLongs, writeShorts, writeString, writeString, writeVarInt, writeVarLong

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - UnsafeByteArrayOutputStream
```
public UnsafeByteArrayOutputStream()
```
    Constructor
  - UnsafeByteArrayOutputStream
```
public UnsafeByteArrayOutputStream(int size)
```
    Constructor
    
    Parameters:
    
    size - Initial size of the underlying byte array
  - UnsafeByteArrayOutputStream
```
public UnsafeByteArrayOutputStream(byte[] buf)
```
    Constructor to take in a buffer
    
    Parameters:
    
    buf - Buffer to start with, or if null, create own buffer
  - UnsafeByteArrayOutputStream
```
public UnsafeByteArrayOutputStream(byte[] buf,
                                   int pos)
```
    Constructor to take in a buffer with a given position into that buffer
    
    Parameters:
    
    buf - Buffer to start with
    
    pos - Position to write at the buffer
- Method Detail
  - require
```
protected boolean require(int size)
```
    Ensure that this buffer has enough remaining space to add the size. Creates and copies to a new buffer if necessary
    
    Overrides:
    
    require in class com.esotericsoftware.kryo.io.Output
    
    Parameters:
    
    size - Size to add
  - getByteArray
```
public byte[] getByteArray()
```
    Description copied from interface: ExtendedDataOutput
    
    Get the internal byte array (if possible), read-only
    
    Specified by:
    
    getByteArray in interface ExtendedDataOutput
    
    Returns:
    
    Internal byte array (do not modify)
  - toByteArray
```
public byte[] toByteArray()
```
    Description copied from interface: ExtendedDataOutput
    
    Copies the internal byte array
    
    Specified by:
    
    toByteArray in interface ExtendedDataOutput
    
    Returns:
    
    Copied byte array
  - toByteArray
```
public byte[] toByteArray(int offset,
                          int length)
```
    Description copied from interface: ExtendedDataOutput
    
    Return a copy of slice of byte array
    
    Specified by:
    
    toByteArray in interface ExtendedDataOutput
    
    Parameters:
    
    offset - offset of array
    
    length - length of slice
    
    Returns:
    
    byte array
  - reset
```
public void reset()
```
    Description copied from interface: ExtendedDataOutput
    
    Clears the buffer
    
    Specified by:
    
    reset in interface ExtendedDataOutput
  - getPos
```
public int getPos()
```
    Description copied from interface: ExtendedDataOutput
    
    Get the position in the output stream
    
    Specified by:
    
    getPos in interface ExtendedDataOutput
    
    Returns:
    
    Position in the output stream
  - write
```
public void write(int b)
```
    Specified by:
    
    write in interface DataOutput
    
    Overrides:
    
    write in class com.esotericsoftware.kryo.io.Output
  - write
```
public void write(byte[] b)
```
    Specified by:
    
    write in interface DataOutput
    
    Overrides:
    
    write in class com.esotericsoftware.kryo.io.Output
  - write
```
public void write(byte[] b,
                  int off,
                  int len)
```
    Specified by:
    
    write in interface DataOutput
    
    Overrides:
    
    write in class com.esotericsoftware.kryo.io.Output
  - writeBoolean
```
public void writeBoolean(boolean v)
```
    Specified by:
    
    writeBoolean in interface DataOutput
    
    Overrides:
    
    writeBoolean in class com.esotericsoftware.kryo.io.Output
  - writeByte
```
public void writeByte(int v)
```
    Specified by:
    
    writeByte in interface DataOutput
    
    Overrides:
    
    writeByte in class com.esotericsoftware.kryo.io.Output
  - writeShort
```
public void writeShort(int v)
```
    Specified by:
    
    writeShort in interface DataOutput
    
    Overrides:
    
    writeShort in class com.esotericsoftware.kryo.io.Output
  - writeChar
```
public void writeChar(int v)
               throws IOException
```
    Specified by:
    
    writeChar in interface DataOutput
    
    Throws:
    
    IOException
  - writeChar
```
public void writeChar(char v)
```
    Overrides:
    
    writeChar in class com.esotericsoftware.kryo.io.Output
  - writeInt
```
public void writeInt(int v)
```
    Specified by:
    
    writeInt in interface DataOutput
    
    Overrides:
    
    writeInt in class com.esotericsoftware.kryo.io.Output
  - ensureWritable
```
public void ensureWritable(int minSize)
```
    Description copied from interface: ExtendedDataOutput
    
    Ensure that backing byte structure has at least minSize additional bytes
    
    Specified by:
    
    ensureWritable in interface ExtendedDataOutput
    
    Parameters:
    
    minSize - additional size required
  - skipBytes
```
public void skipBytes(int bytesToSkip)
```
    Description copied from interface: ExtendedDataOutput
    
    Skip some number of bytes.
    
    Specified by:
    
    skipBytes in interface ExtendedDataOutput
    
    Parameters:
    
    bytesToSkip - Number of bytes to skip
  - writeInt
```
public void writeInt(int pos,
                     int value)
```
    Description copied from interface: ExtendedDataOutput
    
    In order to write a size as a first part of an data output, it is useful to be able to write an int at an arbitrary location in the stream
    
    Specified by:
    
    writeInt in interface ExtendedDataOutput
    
    Parameters:
    
    pos - Byte position in the output stream
    
    value - Value to write
  - writeLong
```
public void writeLong(long v)
```
    Specified by:
    
    writeLong in interface DataOutput
    
    Overrides:
    
    writeLong in class com.esotericsoftware.kryo.io.Output
  - writeFloat
```
public void writeFloat(float v)
```
    Specified by:
    
    writeFloat in interface DataOutput
    
    Overrides:
    
    writeFloat in class com.esotericsoftware.kryo.io.Output
  - writeDouble
```
public void writeDouble(double v)
```
    Specified by:
    
    writeDouble in interface DataOutput
    
    Overrides:
    
    writeDouble in class com.esotericsoftware.kryo.io.Output
  - writeBytes
```
public void writeBytes(String s)
                throws IOException
```
    Specified by:
    
    writeBytes in interface DataOutput
    
    Throws:
    
    IOException
  - writeChars
```
public void writeChars(String s)
                throws IOException
```
    Specified by:
    
    writeChars in interface DataOutput
    
    Throws:
    
    IOException
  - writeUTF
```
public void writeUTF(String s)
              throws IOException
```
    Specified by:
    
    writeUTF in interface DataOutput
    
    Throws:
    
    IOException

Class UnsafeByteArrayOutputStream

Field Summary

Fields inherited from class com.esotericsoftware.kryo.io.Output

Constructor Summary

Method Summary

Methods inherited from class com.esotericsoftware.kryo.io.Output

Methods inherited from class java.lang.Object

Constructor Detail

UnsafeByteArrayOutputStream

UnsafeByteArrayOutputStream

UnsafeByteArrayOutputStream

UnsafeByteArrayOutputStream

Method Detail

require

getByteArray

toByteArray

toByteArray

reset

getPos

write

write

write

writeBoolean

writeByte

writeShort

writeChar

writeChar

writeInt

ensureWritable

skipBytes

writeInt

writeLong

writeFloat

writeDouble

writeBytes

writeChars

writeUTF