Module id.kineticstreamer

Package id.kineticstreamer

Class KineticStreamReader

Object

KineticStreamReader

public class KineticStreamReader
extends Object

Reads Java objects from kinetic streams

Constructor Summary

Constructors

Constructor	Description
KineticStreamReader(InputKineticStream in)

Method Summary

Modifier and Type	Method	Description
<T> T	read(Class<T> type)	Reads an object from kinetic stream
KineticStreamReader	withController(KineticStreamController controller)

Methods inherited from class Object

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

Constructor Details

KineticStreamReader

public KineticStreamReader(InputKineticStream in)

Method Details

withController

public KineticStreamReader withController(KineticStreamController controller)

read

public <T> T read(Class<T> type)
           throws Exception

Reads an object from kinetic stream

Throws:

Exception