| Constructor and Description |
|---|
KinesisConnectorRecordProcessor(IBuffer<T> buffer,
IFilter<T> filter,
IEmitter<U> emitter,
ITransformerBase<T,U> transformer,
KinesisConnectorConfiguration configuration) |
| Modifier and Type | Class and Description |
|---|---|
class |
DynamoDBEmitter
This class is used to store records from a stream in an Amazon DynamoDB table.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ElasticsearchEmitter |
| Modifier and Type | Method and Description |
|---|---|
IEmitter<U> |
IKinesisConnectorPipeline.getEmitter(KinesisConnectorConfiguration configuration)
Return an instance of the users implementation of IEmitter
|
| Modifier and Type | Class and Description |
|---|---|
class |
RedshiftBasicEmitter
This class is an implementation of IEmitter that emits records into Amazon Redshift one by one.
|
class |
RedshiftManifestEmitter
This implementation of IEmitter collects filenames from an Amazon Kinesis stream that has been started by
a S3ManifestEmitter.
|
| Modifier and Type | Class and Description |
|---|---|
class |
S3Emitter
This implementation of IEmitter is used to store files from an Amazon Kinesis stream in S3.
|
class |
S3ManifestEmitter
This implementaion of IEmitter inserts records into Amazon S3 and emits filenames into a separate
Amazon Kinesis stream.
|
Copyright © 2016. All rights reserved.