com.amazonaws.services.kinesis.connectors.interfaces

Interface ICollectionTransformer<T,U>

Type Parameters:

T - the data type stored in the record

U - the data type to emit

All Superinterfaces:

ITransformerBase<T,U>

public interface ICollectionTransformer<T,U>
extends ITransformerBase<T,U>

ICollectionTransformer is used to transform data from an Amazon Kinesis Record (byte array) to a collection of the data model class (T) for processing in the application and from the data model class to the output type (U) for the emitter.

Method Summary

Modifier and Type	Method and Description
Collection<T>	toClass(com.amazonaws.services.kinesis.model.Record record) Transform record into a collection of object of their original class.

Methods inherited from interface com.amazonaws.services.kinesis.connectors.interfaces.ITransformerBase

fromClass

Method Detail

toClass

Collection<T> toClass(com.amazonaws.services.kinesis.model.Record record)
               throws IOException

Transform record into a collection of object of their original class.

Parameters:

record - raw record from the Amazon Kinesis stream

Returns:

data as its original class

Throws:

IOException - could not convert the record to a Collection