Module id.kineticstreamer

Package id.kineticstreamer

Interface InputKineticStream

All Superinterfaces:

AutoCloseable

All Known Implementing Classes:

ByteInputKineticStream, CsvInputKineticStream

public interface InputKineticStream
extends AutoCloseable

Interface which needs to be implemented to support deserialization of new types of kinetic streams.

All of them read values from the stream which were previously written there by OutputKineticStream.

Methods for reading arrays are called with the value from the field of the object which is being deserialized. This helps to populate fixed size array fields. Users can populate such arrays directly and then return reference back so that kineticstreamer don't have to allocate new arrays for them.

Each method additionally accepts all field annotations associated with the field, value for which is currently read.

Method Summary

Modifier and Type	Method	Description
Object[]	readArray(Object[] a, Class<?> type, Annotation[] fieldAnnotations)
boolean	readBool(Annotation[] fieldAnnotations)
boolean[]	readBooleanArray(boolean[] a, Annotation[] fieldAnnotations)
byte	readByte(Annotation[] fieldAnnotations)
byte[]	readByteArray(byte[] a, Annotation[] fieldAnnotations)
char	readChar(Annotation[] fieldAnnotations)
char[]	readCharArray(char[] a, Annotation[] fieldAnnotations)
double	readDouble(Annotation[] fieldAnnotations)
double[]	readDoubleArray(double[] a, Annotation[] fieldAnnotations)
float	readFloat(Annotation[] fieldAnnotations)
float[]	readFloatArray(float[] a, Annotation[] fieldAnnotations)
int	readInt(Annotation[] fieldAnnotations)
int[]	readIntArray(int[] a, Annotation[] fieldAnnotations)
long	readLong(Annotation[] fieldAnnotations)
long[]	readLongArray(long[] a, Annotation[] fieldAnnotations)
short	readShort(Annotation[] fieldAnnotations)
short[]	readShortArray(short[] a, Annotation[] fieldAnnotations)
String	readString(Annotation[] fieldAnnotations)
String[]	readStringArray(String[] a, Annotation[] fieldAnnotations)

Methods inherited from interface AutoCloseable

close

Method Details

readString

String readString(Annotation[] fieldAnnotations)
           throws Exception

Throws:

Exception

readInt

int readInt(Annotation[] fieldAnnotations)
     throws Exception

Throws:

Exception

readFloat

float readFloat(Annotation[] fieldAnnotations)
         throws Exception

Throws:

Exception

readDouble

double readDouble(Annotation[] fieldAnnotations)
           throws Exception

Throws:

Exception

readBool

boolean readBool(Annotation[] fieldAnnotations)
          throws Exception

Throws:

Exception

readByte

byte readByte(Annotation[] fieldAnnotations)
       throws Exception

Throws:

Exception

readChar

char readChar(Annotation[] fieldAnnotations)
       throws Exception

Throws:

Exception

readArray

Object[] readArray(Object[] a,
 Class<?> type,
 Annotation[] fieldAnnotations)
            throws Exception

Throws:

Exception

readIntArray

int[] readIntArray(int[] a,
 Annotation[] fieldAnnotations)
            throws Exception

Throws:

Exception

readByteArray

byte[] readByteArray(byte[] a,
 Annotation[] fieldAnnotations)
              throws Exception

Throws:

Exception

readDoubleArray

double[] readDoubleArray(double[] a,
 Annotation[] fieldAnnotations)
                  throws Exception

Throws:

Exception

readBooleanArray

boolean[] readBooleanArray(boolean[] a,
 Annotation[] fieldAnnotations)
                    throws Exception

Throws:

Exception

readStringArray

String[] readStringArray(String[] a,
 Annotation[] fieldAnnotations)
                  throws Exception

Throws:

Exception

readLong

long readLong(Annotation[] fieldAnnotations)
       throws Exception

Throws:

Exception

readLongArray

long[] readLongArray(long[] a,
 Annotation[] fieldAnnotations)
              throws Exception

Throws:

Exception

readShort

short readShort(Annotation[] fieldAnnotations)
         throws Exception

Throws:

Exception

readShortArray

short[] readShortArray(short[] a,
 Annotation[] fieldAnnotations)
                throws Exception

Throws:

Exception

readCharArray

char[] readCharArray(char[] a,
 Annotation[] fieldAnnotations)
              throws Exception

Throws:

Exception

readFloatArray

float[] readFloatArray(float[] a,
 Annotation[] fieldAnnotations)
                throws Exception

Throws:

Exception