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 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 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, ...
-