com.amazonaws.services.kinesis.connectors

Class KinesisConnectorExecutorBase<T,U>

java.lang.Object

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

All Implemented Interfaces:

Runnable

public abstract class KinesisConnectorExecutorBase<T,U>
extends Object
implements Runnable

Field Summary

Fields

Modifier and Type	Field and Description
protected com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker	worker

Constructor Summary

Constructors

Constructor and Description
KinesisConnectorExecutorBase()

Method Summary

Modifier and Type	Method and Description
abstract KinesisConnectorRecordProcessorFactory<T,U>	getKinesisConnectorRecordProcessorFactory() This method returns a KinesisConnectorRecordProcessorFactory that contains the appropriate IKinesisConnectorPipeline for the Amazon Kinesis Enabled Application
protected void	initialize(KinesisConnectorConfiguration kinesisConnectorConfiguration) Initialize the Amazon Kinesis Client Library configuration and worker
protected void	initialize(KinesisConnectorConfiguration kinesisConnectorConfiguration, com.amazonaws.services.kinesis.metrics.interfaces.IMetricsFactory metricFactory) Initialize the Amazon Kinesis Client Library configuration and worker with metrics factory
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

worker

protected com.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker worker

Constructor Detail

KinesisConnectorExecutorBase

public KinesisConnectorExecutorBase()

Method Detail

initialize

protected void initialize(KinesisConnectorConfiguration kinesisConnectorConfiguration)

Initialize the Amazon Kinesis Client Library configuration and worker

Parameters:

kinesisConnectorConfiguration - Amazon Kinesis connector configuration

initialize

protected void initialize(KinesisConnectorConfiguration kinesisConnectorConfiguration,
                          com.amazonaws.services.kinesis.metrics.interfaces.IMetricsFactory metricFactory)

Initialize the Amazon Kinesis Client Library configuration and worker with metrics factory

Parameters:

kinesisConnectorConfiguration - Amazon Kinesis connector configuration

metricFactory - would be used to emit metrics in Amazon Kinesis Client Library

run

public void run()

Specified by:

run in interface Runnable

getKinesisConnectorRecordProcessorFactory

public abstract KinesisConnectorRecordProcessorFactory<T,U> getKinesisConnectorRecordProcessorFactory()

This method returns a KinesisConnectorRecordProcessorFactory that contains the appropriate IKinesisConnectorPipeline for the Amazon Kinesis Enabled Application

Returns:

a KinesisConnectorRecordProcessorFactory that contains the appropriate IKinesisConnectorPipeline for the Amazon Kinesis Enabled Application