org.apache.storm.kinesis.spout

Class KinesisConnectionInfo

java.lang.Object

org.apache.storm.kinesis.spout.KinesisConnectionInfo

All Implemented Interfaces:

Serializable

public class KinesisConnectionInfo
extends Object
implements Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
KinesisConnectionInfo(com.amazonaws.auth.AWSCredentialsProvider credentialsProvider, com.amazonaws.ClientConfiguration clientConfiguration, com.amazonaws.regions.Regions region, Integer recordsLimit) Create a new Kinesis connection info.

Method Summary

Modifier and Type	Method and Description
com.amazonaws.ClientConfiguration	getClientConfiguration()
com.amazonaws.auth.AWSCredentialsProvider	getCredentialsProvider()
Integer	getRecordsLimit()
com.amazonaws.regions.Regions	getRegion()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

KinesisConnectionInfo

public KinesisConnectionInfo(com.amazonaws.auth.AWSCredentialsProvider credentialsProvider,
                             com.amazonaws.ClientConfiguration clientConfiguration,
                             com.amazonaws.regions.Regions region,
                             Integer recordsLimit)

Create a new Kinesis connection info.

Parameters:

credentialsProvider - implementation to provide credentials to connect to kinesis

clientConfiguration - client configuration to pass to kinesis client

region - region to connect to

recordsLimit - max records to be fetched in a getRecords request to kinesis

Method Detail

getRecordsLimit

public Integer getRecordsLimit()

getCredentialsProvider

public com.amazonaws.auth.AWSCredentialsProvider getCredentialsProvider()

getClientConfiguration

public com.amazonaws.ClientConfiguration getClientConfiguration()

getRegion

public com.amazonaws.regions.Regions getRegion()

toString

public String toString()

Overrides:

toString in class Object