| Class | Description |
|---|---|
| BasicJsonTransformer<T,U> |
This class implements the ITransformer interface and provides an implementation of the toClass()
method for deserializing and serializing JSON strings.
|
| KinesisClientLibraryPipelinedRecordProcessor |
Wraps an
IRecordProcessor to pipeline fetching and processing records. |
| KinesisClientLibraryPipelinedRecordProcessorFactory |
Wraps an
IRecordProcessorFactory to decouple fetching records and processing records in the created IRecordProcessor. |
| KinesisConnectorConfiguration |
This class contains constants used to configure AWS Services in Amazon Kinesis Connectors.
|
| KinesisConnectorExecutorBase<T,U> | |
| KinesisConnectorRecordProcessor<T,U> |
This is the base class for any KinesisConnector.
|
| KinesisConnectorRecordProcessorFactory<T,U> |
This class is used to generate KinesisConnectorRecordProcessors that operate using the user's
implemented classes.
|
| UnmodifiableBuffer<T> |
This class is a wrapper on an IBuffer that limits the functionality of the buffer.
|
Copyright © 2016. All rights reserved.