Module id.kineticstreamer

Package id.kineticstreamer.streams

Class ByteOutputKineticStream

Object

ByteOutputKineticStream

All Implemented Interfaces:

OutputKineticStream, AutoCloseable

public class ByteOutputKineticStream
extends Object
implements OutputKineticStream

Kinetic stream implementation for serialization of Java objects into sequence of bytes.

Any array 'A' serialized as follows: writeInt(A.length) | KineticStreamWriter::write(a[0]) | ... | KineticStreamWriter::write(a[N])

Where write call for each item will use KineticStreamWriter on same kinetic stream object (ie. 'this').

Constructor Summary

Constructors

Constructor	Description
ByteOutputKineticStream(DataOutput out)	Creates byte kinetic stream and attaches it to 'out'

Method Summary

Modifier and Type	Method	Description
void	close()
void	writeArray(Object[] array, Annotation[] fieldAnnotations)
void	writeBoolean(Boolean b, Annotation[] fieldAnnotations)
void	writeBooleanArray(boolean[] array, Annotation[] fieldAnnotations)
void	writeByte(Byte b, Annotation[] fieldAnnotations)
void	writeByteArray(byte[] array, Annotation[] fieldAnnotations)
void	writeChar(Character ch, Annotation[] fieldAnnotations)
void	writeCharArray(char[] array, Annotation[] fieldAnnotations)
void	writeDouble(Double f, Annotation[] fieldAnnotations)
void	writeDoubleArray(double[] array, Annotation[] fieldAnnotations)
void	writeFloat(Float f, Annotation[] fieldAnnotations)
void	writeFloatArray(float[] array, Annotation[] fieldAnnotations)
void	writeInt(Integer i, Annotation[] fieldAnnotations)
void	writeIntArray(int[] array, Annotation[] fieldAnnotations)
void	writeLong(Long l, Annotation[] fieldAnnotations)
void	writeShort(Short s, Annotation[] fieldAnnotations)
void	writeShortArray(short[] a, Annotation[] fieldAnnotations)
void	writeString(String str, Annotation[] fieldAnnotations)
void	writeStringArray(String[] array, Annotation[] fieldAnnotations)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ByteOutputKineticStream

public ByteOutputKineticStream(DataOutput out)

Creates byte kinetic stream and attaches it to 'out'

Method Details

writeString

public void writeString(String str,
 Annotation[] fieldAnnotations)
                 throws IOException

Specified by:

writeString in interface OutputKineticStream

Throws:

IOException

writeInt

public void writeInt(Integer i,
 Annotation[] fieldAnnotations)
              throws IOException

Specified by:

writeInt in interface OutputKineticStream

Throws:

IOException

writeDouble

public void writeDouble(Double f,
 Annotation[] fieldAnnotations)
                 throws IOException

Specified by:

writeDouble in interface OutputKineticStream

Throws:

IOException

writeFloat

public void writeFloat(Float f,
 Annotation[] fieldAnnotations)
                throws IOException

Specified by:

writeFloat in interface OutputKineticStream

Throws:

IOException

writeBoolean

public void writeBoolean(Boolean b,
 Annotation[] fieldAnnotations)
                  throws IOException

Specified by:

writeBoolean in interface OutputKineticStream

Throws:

IOException

writeArray

public void writeArray(Object[] array,
 Annotation[] fieldAnnotations)
                throws Exception

Specified by:

writeArray in interface OutputKineticStream

Throws:

Exception

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

writeByte

public void writeByte(Byte b,
 Annotation[] fieldAnnotations)
               throws Exception

Specified by:

writeByte in interface OutputKineticStream

Throws:

Exception

writeChar

public void writeChar(Character ch,
 Annotation[] fieldAnnotations)
               throws Exception

Specified by:

writeChar in interface OutputKineticStream

Throws:

Exception

writeIntArray

public void writeIntArray(int[] array,
 Annotation[] fieldAnnotations)
                   throws Exception

Specified by:

writeIntArray in interface OutputKineticStream

Throws:

Exception

writeByteArray

public void writeByteArray(byte[] array,
 Annotation[] fieldAnnotations)
                    throws Exception

Specified by:

writeByteArray in interface OutputKineticStream

Throws:

Exception

writeDoubleArray

public void writeDoubleArray(double[] array,
 Annotation[] fieldAnnotations)
                      throws Exception

Specified by:

writeDoubleArray in interface OutputKineticStream

Throws:

Exception

writeBooleanArray

public void writeBooleanArray(boolean[] array,
 Annotation[] fieldAnnotations)
                       throws Exception

Specified by:

writeBooleanArray in interface OutputKineticStream

Throws:

Exception

writeLong

public void writeLong(Long l,
 Annotation[] fieldAnnotations)
               throws Exception

Specified by:

writeLong in interface OutputKineticStream

Throws:

Exception

writeShort

public void writeShort(Short s,
 Annotation[] fieldAnnotations)
                throws Exception

Specified by:

writeShort in interface OutputKineticStream

Throws:

Exception

writeShortArray

public void writeShortArray(short[] a,
 Annotation[] fieldAnnotations)
                     throws Exception

Specified by:

writeShortArray in interface OutputKineticStream

Throws:

Exception

writeStringArray

public void writeStringArray(String[] array,
 Annotation[] fieldAnnotations)
                      throws Exception

Specified by:

writeStringArray in interface OutputKineticStream

Throws:

Exception

writeCharArray

public void writeCharArray(char[] array,
 Annotation[] fieldAnnotations)
                    throws Exception

Specified by:

writeCharArray in interface OutputKineticStream

Throws:

Exception

writeFloatArray

public void writeFloatArray(float[] array,
 Annotation[] fieldAnnotations)
                     throws Exception

Specified by:

writeFloatArray in interface OutputKineticStream

Throws:

Exception