IKinesisConnectorPipeline (Amazon Kinesis Connector Library 1.3.0 API)

```
public interface IKinesisConnectorPipeline<T,U>
```
This interface is used by the KinesisConnectorRecordProcessorFactory to obtain instances of the user's implemented classes. Each method takes the applications configuration as an argument. The user should implement this such that each method returns a configured implementation of each interface. It has two parameter types, the data input type (T) and the data output type (U). Records come in as a byte[] and are transformed to a T. Then they are buffered in T form. When the buffer is full, T's are converted to U's and passed to the emitter.

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`IBuffer<T>`	`getBuffer(KinesisConnectorConfiguration configuration)` Return an instance of the users implementation of IBuffer
`IEmitter<U>`	`getEmitter(KinesisConnectorConfiguration configuration)` Return an instance of the users implementation of IEmitter
`IFilter<T>`	`getFilter(KinesisConnectorConfiguration configuration)` Return an instance of the users implementation of IFilter.
`ITransformerBase<T,U>`	`getTransformer(KinesisConnectorConfiguration configuration)` Return an instance of the users implementation of ITransformer.

Interface IKinesisConnectorPipeline<T,U>