com.amazonaws.services.kinesis.connectors.interfaces

Interface ITransformer<T,U>

Type Parameters:

T - the data type stored in the record

U - the data type to emit

All Superinterfaces:

ITransformerBase<T,U>

All Known Subinterfaces:

DynamoDBTransformer<T>

All Known Implementing Classes:

BasicJsonTransformer, JsonToByteArrayTransformer, RedshiftTransformer, StringToByteArrayTransformer, StringToStringTransformer

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

ITransformer is used to transform data from a Record (byte array) to 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
T	toClass(com.amazonaws.services.kinesis.model.Record record) Transform record into an object of its original class.

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

fromClass

Method Detail

toClass

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

Transform record into an object of its 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 T