| Package | Description |
|---|---|
| com.amazonaws.services.kinesis.connectors | |
| com.amazonaws.services.kinesis.connectors.impl | |
| com.amazonaws.services.kinesis.connectors.interfaces |
| 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 |
AllPassFilter<T>
This class is a basic implementation of IFilter that returns true for all records.
|
| Modifier and Type | Method and Description |
|---|---|
IFilter<T> |
IKinesisConnectorPipeline.getFilter(KinesisConnectorConfiguration configuration)
Return an instance of the users implementation of IFilter.
|
Copyright © 2016. All rights reserved.