Uses of Class
org.apache.storm.kafka.spout.KafkaSpoutRetryExponentialBackoff.TimeInterval

Packages that use KafkaSpoutRetryExponentialBackoff.TimeInterval

Package	Description
org.apache.storm.kafka.spout

Uses of KafkaSpoutRetryExponentialBackoff.TimeInterval in org.apache.storm.kafka.spout

Methods in org.apache.storm.kafka.spout that return KafkaSpoutRetryExponentialBackoff.TimeInterval

Modifier and Type	Method and Description
static KafkaSpoutRetryExponentialBackoff.TimeInterval	KafkaSpoutRetryExponentialBackoff.TimeInterval.microSeconds(long length)
static KafkaSpoutRetryExponentialBackoff.TimeInterval	KafkaSpoutRetryExponentialBackoff.TimeInterval.milliSeconds(long length)
static KafkaSpoutRetryExponentialBackoff.TimeInterval	KafkaSpoutRetryExponentialBackoff.TimeInterval.seconds(long length)

Constructors in org.apache.storm.kafka.spout with parameters of type KafkaSpoutRetryExponentialBackoff.TimeInterval

Constructor and Description

KafkaSpoutRetryExponentialBackoff(KafkaSpoutRetryExponentialBackoff.TimeInterval initialDelay, KafkaSpoutRetryExponentialBackoff.TimeInterval delayPeriod, int maxRetries, KafkaSpoutRetryExponentialBackoff.TimeInterval maxDelay) The time stamp of the next retry is scheduled according to the exponential backoff formula ( geometric progression): nextRetry = failCount == 1 ? currentTime + initialDelay : currentTime + delayPeriod^(failCount-1) where failCount = 1, 2, 3, … nextRetry = Min(nextRetry, currentTime + maxDelay).