com.amazonaws.services.kinesis.connectors.impl

Class StringToByteArrayTransformer

java.lang.Object

com.amazonaws.services.kinesis.connectors.impl.StringToByteArrayTransformer

All Implemented Interfaces:

ITransformer<String,byte[]>, ITransformerBase<String,byte[]>

public class StringToByteArrayTransformer
extends Object
implements ITransformer<String,byte[]>

This class is an implementation of the ITransformer to transform between raw Amazon Kinesis records and strings. It assumes that the Record parameter of toClass() is a byte array representation of a string.

Constructor Summary

Constructors

Constructor and Description
StringToByteArrayTransformer()

Method Summary

Modifier and Type	Method and Description
byte[]	fromClass(String record) Transform record from its original class to final output class.
String	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

Constructor Detail

StringToByteArrayTransformer

public StringToByteArrayTransformer()

Method Detail

toClass

public String toClass(com.amazonaws.services.kinesis.model.Record record)

Description copied from interface: ITransformer

Transform record into an object of its original class.

Specified by:

toClass in interface ITransformer<String,byte[]>

Parameters:

record - raw record from the Amazon Kinesis stream

Returns:

data as its original class

fromClass

public byte[] fromClass(String record)

Description copied from interface: ITransformerBase

Transform record from its original class to final output class.

Specified by:

fromClass in interface ITransformerBase<String,byte[]>

Parameters:

record - data as its original class

Returns:

U the object as its final class