com.amazonaws.services.kinesis.connectors.redshift

Class RedshiftTransformer<T>

java.lang.Object

com.amazonaws.services.kinesis.connectors.BasicJsonTransformer<T,byte[]>

com.amazonaws.services.kinesis.connectors.impl.JsonToByteArrayTransformer<T>

com.amazonaws.services.kinesis.connectors.redshift.RedshiftTransformer<T>

Type Parameters:

T -

All Implemented Interfaces:

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

public abstract class RedshiftTransformer<T>
extends JsonToByteArrayTransformer<T>

This class is an implementation of the ITransformer interface and an extension of the BasicJsonTransformer class. The abstract method toDelimitedString() requires implementing classes to output a delimited-string representation of the data model that is compatible with an insertion into Amazon Redshift.

Field Summary

Fields inherited from class com.amazonaws.services.kinesis.connectors.BasicJsonTransformer

inputClass

Constructor Summary

Constructors

Constructor and Description
RedshiftTransformer(Class<T> clazz)

Method Summary

Modifier and Type	Method and Description
byte[]	fromClass(T record) Transform record from its original class to final output class.
abstract String	toDelimitedString(T recordObject) This method requires implementing classes to output a string representation of the data model that is compatible with Amazon Redshift.

Methods inherited from class com.amazonaws.services.kinesis.connectors.BasicJsonTransformer

toClass

Methods inherited from class java.lang.Object

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

Constructor Detail

RedshiftTransformer

public RedshiftTransformer(Class<T> clazz)

Method Detail

toDelimitedString

public abstract String toDelimitedString(T recordObject)

This method requires implementing classes to output a string representation of the data model that is compatible with Amazon Redshift. This string will be used to insert records into an Amazon Redshift table, and should be in a delimited format.

Parameters:

recordObject - the instance of the data model to convert to delimited string.

Returns:

a delimited string representation of the data model that is compatible with Amazon Redshift

fromClass

public byte[] fromClass(T record)

Description copied from interface: ITransformerBase

Transform record from its original class to final output class.

Specified by:

fromClass in interface ITransformerBase<T,byte[]>

Overrides:

fromClass in class JsonToByteArrayTransformer<T>

Parameters:

record - data as its original class

Returns:

U the object as its final class