org.apache.storm.kinesis.spout

Class KinesisConfig

java.lang.Object

org.apache.storm.kinesis.spout.KinesisConfig

All Implemented Interfaces:

Serializable

public class KinesisConfig
extends Object
implements Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
KinesisConfig(String streamName, com.amazonaws.services.kinesis.model.ShardIteratorType shardIteratorType, RecordToTupleMapper recordToTupleMapper, Date timestamp, FailedMessageRetryHandler failedMessageRetryHandler, ZkInfo zkInfo, KinesisConnectionInfo kinesisConnectionInfo, Long maxUncommittedRecords)

Method Summary

Modifier and Type	Method and Description
FailedMessageRetryHandler	getFailedMessageRetryHandler()
KinesisConnectionInfo	getKinesisConnectionInfo()
Long	getMaxUncommittedRecords()
RecordToTupleMapper	getRecordToTupleMapper()
com.amazonaws.services.kinesis.model.ShardIteratorType	getShardIteratorType()
String	getStreamName()
Date	getTimestamp()
ZkInfo	getZkInfo()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

KinesisConfig

public KinesisConfig(String streamName,
                     com.amazonaws.services.kinesis.model.ShardIteratorType shardIteratorType,
                     RecordToTupleMapper recordToTupleMapper,
                     Date timestamp,
                     FailedMessageRetryHandler failedMessageRetryHandler,
                     ZkInfo zkInfo,
                     KinesisConnectionInfo kinesisConnectionInfo,
                     Long maxUncommittedRecords)

Method Detail

getStreamName

public String getStreamName()

getShardIteratorType

public com.amazonaws.services.kinesis.model.ShardIteratorType getShardIteratorType()

getRecordToTupleMapper

public RecordToTupleMapper getRecordToTupleMapper()

getTimestamp

public Date getTimestamp()

getFailedMessageRetryHandler

public FailedMessageRetryHandler getFailedMessageRetryHandler()

getZkInfo

public ZkInfo getZkInfo()

getKinesisConnectionInfo

public KinesisConnectionInfo getKinesisConnectionInfo()

getMaxUncommittedRecords

public Long getMaxUncommittedRecords()

toString

public String toString()

Overrides:

toString in class Object