com.amazonaws.services.kinesis.connectors

Class BasicJsonTransformer<T,U>

java.lang.Object

com.amazonaws.services.kinesis.connectors.BasicJsonTransformer<T,U>

Type Parameters:

T -

All Implemented Interfaces:

ITransformer<T,U>, ITransformerBase<T,U>

Direct Known Subclasses:

JsonToByteArrayTransformer

public abstract class BasicJsonTransformer<T,U>
extends Object
implements ITransformer<T,U>

This class implements the ITransformer interface and provides an implementation of the toClass() method for deserializing and serializing JSON strings. The constructor takes the class to transform to/from JSON. The Record parameter of the toClass() method is expected to contain a byte representation of a JSON string.

Field Summary

Fields

Modifier and Type	Field and Description
protected Class<T>	inputClass

Constructor Summary

Constructors

Constructor and Description
BasicJsonTransformer(Class<T> inputClass)

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 class java.lang.Object

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

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

fromClass

Field Detail

inputClass

protected Class<T> inputClass

Constructor Detail

BasicJsonTransformer

public BasicJsonTransformer(Class<T> inputClass)

Method Detail

toClass

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

Description copied from interface: ITransformer

Transform record into an object of its original class.

Specified by:

toClass in interface ITransformer<T,U>

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