| Package | Description |
|---|---|
| com.amazonaws.services.kinesis.connectors | |
| com.amazonaws.services.kinesis.connectors.impl | |
| com.amazonaws.services.kinesis.connectors.interfaces |
| Modifier and Type | Class and Description |
|---|---|
class |
UnmodifiableBuffer<T>
This class is a wrapper on an IBuffer that limits the functionality of the buffer.
|
| Constructor and Description |
|---|
KinesisConnectorRecordProcessor(IBuffer<T> buffer,
IFilter<T> filter,
IEmitter<U> emitter,
ITransformerBase<T,U> transformer,
KinesisConnectorConfiguration configuration) |
UnmodifiableBuffer(IBuffer<?> buf,
List<T> records) |
UnmodifiableBuffer(IBuffer<T> buf) |
| Modifier and Type | Class and Description |
|---|---|
class |
BasicMemoryBuffer<T>
This class is a basic implementation of the IBuffer interface.
|
| Modifier and Type | Method and Description |
|---|---|
IBuffer<T> |
IKinesisConnectorPipeline.getBuffer(KinesisConnectorConfiguration configuration)
Return an instance of the users implementation of IBuffer
|
Copyright © 2016. All rights reserved.