| Interface | Description |
|---|---|
| IBuffer<T> |
IBuffer defines a buffer used to store records streamed through Amazon Kinesis.
|
| 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.
|
| IEmitter<T> |
IEmitter takes a full buffer and processes the stored records.
|
| IFilter<T> |
The IFilter is associated with an IBuffer.
|
| IKinesisConnectorPipeline<T,U> |
This interface is used by the KinesisConnectorRecordProcessorFactory to obtain instances of the
user's implemented classes.
|
| 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.
|
| ITransformerBase<T,U> |
Base transformer class to provide backwards compatibility with ITransformer
while supporting the ICollectionTransformer.
|
Copyright © 2016. All rights reserved.