-
- 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
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Object[]
readArray(Class<?> type)
boolean
readBool()
boolean[]
readBooleanArray()
byte
readByte()
byte[]
readByteArray()
double
readDouble()
double[]
readDoubleArray()
float
readFloat()
int
readInt()
int[]
readIntArray()
String
readString()
-
-
-
Method Detail
-
readString
String readString() throws Exception
- Throws:
Exception
-
readInt
int readInt() throws Exception
- Throws:
Exception
-
readFloat
float readFloat() throws Exception
- Throws:
Exception
-
readDouble
double readDouble() throws Exception
- Throws:
Exception
-
readBool
boolean readBool() throws Exception
- Throws:
Exception
-
readByte
byte readByte() throws Exception
- Throws:
Exception
-
readArray
Object[] readArray(Class<?> type) throws Exception
- Throws:
Exception
-
readIntArray
int[] readIntArray() throws Exception
- Throws:
Exception
-
readByteArray
byte[] readByteArray() throws Exception
- Throws:
Exception
-
readDoubleArray
double[] readDoubleArray() throws Exception
- Throws:
Exception
-
readBooleanArray
boolean[] readBooleanArray() throws Exception
- Throws:
Exception
-
-