com.amazonaws.services.kinesis.connectors

Class KinesisConnectorRecordProcessorFactory<T,U>

java.lang.Object

com.amazonaws.services.kinesis.connectors.KinesisConnectorRecordProcessorFactory<T,U>

All Implemented Interfaces:

com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessorFactory

public class KinesisConnectorRecordProcessorFactory<T,U>
extends Object
implements com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessorFactory

This class is used to generate KinesisConnectorRecordProcessors that operate using the user's implemented classes. The createProcessor() method sets the dependencies of the KinesisConnectorRecordProcessor that are specified in the KinesisConnectorPipeline argument, which accesses instances of the users implementations.

Constructor Summary

Constructors

Constructor and Description
KinesisConnectorRecordProcessorFactory(IKinesisConnectorPipeline<T,U> pipeline, KinesisConnectorConfiguration configuration)

Method Summary

Modifier and Type	Method and Description
com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessor	createProcessor()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KinesisConnectorRecordProcessorFactory

public KinesisConnectorRecordProcessorFactory(IKinesisConnectorPipeline<T,U> pipeline,
                                              KinesisConnectorConfiguration configuration)

Method Detail

createProcessor

public com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessor createProcessor()

Specified by:

createProcessor in interface com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessorFactory