| Modifier and Type | Class and Description |
|---|---|
class |
BasicJsonTransformer<T,U>
This class implements the ITransformer interface and provides an implementation of the toClass()
method for deserializing and serializing JSON strings.
|
| Constructor and Description |
|---|
KinesisConnectorRecordProcessor(IBuffer<T> buffer,
IFilter<T> filter,
IEmitter<U> emitter,
ITransformerBase<T,U> transformer,
KinesisConnectorConfiguration configuration) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
DynamoDBTransformer<T>
This interface defines an ITransformer that has an output type of Map of attribute name (String)
to AttributeValue so that the item can be put into Amazon DynamoDB.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ElasticsearchTransformer<T>
Transformer to use in the ElasticsearchPipeline.
|
| Modifier and Type | Class and Description |
|---|---|
class |
JsonToByteArrayTransformer<T>
The JsonToByteArrayTransformer defines a BasicJsonTransformer with byte array for its output
type.
|
class |
StringToByteArrayTransformer
This class is an implementation of the ITransformer to transform between raw Amazon Kinesis records and
strings.
|
class |
StringToStringTransformer
This class is an implementation of the ITransformer to transform between raw Amazon Kinesis records and
strings.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
ICollectionTransformer<T,U>
ICollectionTransformer is used to transform data from an Amazon Kinesis Record (byte array) to
a collection of the data model class (T) for processing in the application and from the
data model class to the output type (U) for the emitter.
|
interface |
ITransformer<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.
|
| Modifier and Type | Method and Description |
|---|---|
ITransformerBase<T,U> |
IKinesisConnectorPipeline.getTransformer(KinesisConnectorConfiguration configuration)
Return an instance of the users implementation of ITransformer.
|
| Modifier and Type | Class and Description |
|---|---|
class |
RedshiftTransformer<T>
This class is an implementation of the ITransformer interface and an extension of the
BasicJsonTransformer class.
|
Copyright © 2016. All rights reserved.