Module id.kineticstreamer

Package id.kineticstreamer.streams

Class CsvInputKineticStream

Object

CsvInputKineticStream

All Implemented Interfaces:

InputKineticStream, AutoCloseable

public class CsvInputKineticStream
extends Object
implements InputKineticStream

Kinetic stream implementation for deserialization of Java objects from stream of CSV lines.

Constructor Summary

Constructors

Constructor	Description
CsvInputKineticStream(BufferedReader lines)	Create CSV kinetic input stream

Method Summary

Modifier and Type	Method	Description
void	close()
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 class Object

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

Constructor Details

CsvInputKineticStream

public CsvInputKineticStream(BufferedReader lines)

Create CSV kinetic input stream

Parameters:

lines - lines reader from CSV file

Method Details

readString

public String readString(Annotation[] fieldAnnotations)
                  throws IOException

Specified by:

readString in interface InputKineticStream

Throws:

IOException

readInt

public int readInt(Annotation[] fieldAnnotations)
            throws IOException

Specified by:

readInt in interface InputKineticStream

Throws:

IOException

readFloat

public float readFloat(Annotation[] fieldAnnotations)
                throws IOException

Specified by:

readFloat in interface InputKineticStream

Throws:

IOException

readDouble

public double readDouble(Annotation[] fieldAnnotations)
                  throws IOException

Specified by:

readDouble in interface InputKineticStream

Throws:

IOException

readBool

public boolean readBool(Annotation[] fieldAnnotations)
                 throws IOException

Specified by:

readBool in interface InputKineticStream

Throws:

IOException

readArray

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

Specified by:

readArray in interface InputKineticStream

Throws:

Exception

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

readByte

public byte readByte(Annotation[] fieldAnnotations)
              throws Exception

Specified by:

readByte in interface InputKineticStream

Throws:

Exception

readIntArray

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

Specified by:

readIntArray in interface InputKineticStream

Throws:

Exception

readByteArray

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

Specified by:

readByteArray in interface InputKineticStream

Throws:

Exception

readDoubleArray

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

Specified by:

readDoubleArray in interface InputKineticStream

Throws:

Exception

readBooleanArray

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

Specified by:

readBooleanArray in interface InputKineticStream

Throws:

Exception

readLong

public long readLong(Annotation[] fieldAnnotations)
              throws Exception

Specified by:

readLong in interface InputKineticStream

Throws:

Exception

readLongArray

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

Specified by:

readLongArray in interface InputKineticStream

Throws:

Exception

readShort

public short readShort(Annotation[] fieldAnnotations)
                throws Exception

Specified by:

readShort in interface InputKineticStream

Throws:

Exception

readShortArray

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

Specified by:

readShortArray in interface InputKineticStream

Throws:

Exception

readStringArray

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

Specified by:

readStringArray in interface InputKineticStream

Throws:

Exception

readChar

public char readChar(Annotation[] fieldAnnotations)
              throws Exception

Specified by:

readChar in interface InputKineticStream

Throws:

Exception

readCharArray

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

Specified by:

readCharArray in interface InputKineticStream

Throws:

Exception

readFloatArray

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

Specified by:

readFloatArray in interface InputKineticStream

Throws:

Exception