com.amazonaws.services.kinesis.connectors.elasticsearch

Class ElasticsearchTransformer<T>

java.lang.Object

com.amazonaws.services.kinesis.connectors.elasticsearch.ElasticsearchTransformer<T>

All Implemented Interfaces:

ITransformerBase<T,ElasticsearchObject>

public abstract class ElasticsearchTransformer<T>
extends Object
implements ITransformerBase<T,ElasticsearchObject>

Transformer to use in the ElasticsearchPipeline. This transformer requires the instantiation of an ElasticsearchObject, which supplies the necessary indexing information to the ElasticsearchEmitter.

Constructor Summary

Constructors

Constructor and Description
ElasticsearchTransformer()

Method Summary

Modifier and Type	Method and Description
abstract ElasticsearchObject	fromClass(T record) Creates an ElasticsearchObject with the information contained in the record.

Methods inherited from class java.lang.Object

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

Constructor Detail

ElasticsearchTransformer

public ElasticsearchTransformer()

Method Detail

fromClass

public abstract ElasticsearchObject fromClass(T record)
                                       throws IOException

Creates an ElasticsearchObject with the information contained in the record.

Specified by:

fromClass in interface ITransformerBase<T,ElasticsearchObject>

Parameters:

record - data as its original class

Returns:

U the object as its final class

Throws:

IOException