| Modifier and Type | Method and Description |
|---|---|
protected void |
KinesisConnectorExecutorBase.initialize(KinesisConnectorConfiguration kinesisConnectorConfiguration)
Initialize the Amazon Kinesis Client Library configuration and worker
|
protected void |
KinesisConnectorExecutorBase.initialize(KinesisConnectorConfiguration kinesisConnectorConfiguration,
com.amazonaws.services.kinesis.metrics.interfaces.IMetricsFactory metricFactory)
Initialize the Amazon Kinesis Client Library configuration and worker with metrics factory
|
| Constructor and Description |
|---|
KinesisConnectorRecordProcessor(IBuffer<T> buffer,
IFilter<T> filter,
IEmitter<U> emitter,
ITransformerBase<T,U> transformer,
KinesisConnectorConfiguration configuration) |
KinesisConnectorRecordProcessorFactory(IKinesisConnectorPipeline<T,U> pipeline,
KinesisConnectorConfiguration configuration) |
| Constructor and Description |
|---|
DynamoDBEmitter(KinesisConnectorConfiguration configuration) |
| Constructor and Description |
|---|
ElasticsearchEmitter(KinesisConnectorConfiguration configuration) |
| Constructor and Description |
|---|
BasicMemoryBuffer(KinesisConnectorConfiguration configuration) |
BasicMemoryBuffer(KinesisConnectorConfiguration configuration,
List<T> buffer) |
| Modifier and Type | Method and Description |
|---|---|
IBuffer<T> |
IKinesisConnectorPipeline.getBuffer(KinesisConnectorConfiguration configuration)
Return an instance of the users implementation of IBuffer
|
IEmitter<U> |
IKinesisConnectorPipeline.getEmitter(KinesisConnectorConfiguration configuration)
Return an instance of the users implementation of IEmitter
|
IFilter<T> |
IKinesisConnectorPipeline.getFilter(KinesisConnectorConfiguration configuration)
Return an instance of the users implementation of IFilter.
|
ITransformerBase<T,U> |
IKinesisConnectorPipeline.getTransformer(KinesisConnectorConfiguration configuration)
Return an instance of the users implementation of ITransformer.
|
| Constructor and Description |
|---|
RedshiftBasicEmitter(KinesisConnectorConfiguration configuration) |
RedshiftManifestEmitter(KinesisConnectorConfiguration configuration) |
| Constructor and Description |
|---|
S3Emitter(KinesisConnectorConfiguration configuration) |
S3ManifestEmitter(KinesisConnectorConfiguration configuration) |
Copyright © 2016. All rights reserved.