Java 类com.amazonaws.services.kinesis.connectors.interfaces.IKinesisConnectorPipeline 实例源码

public KinesisConnectorRecordProcessorFactory(IKinesisConnectorPipeline<T, U> pipeline,
        KinesisConnectorConfiguration configuration) {
    this.configuration = configuration;
    this.pipeline = pipeline;
}