1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.hadoop.hbase.util;
20
21 import java.util.concurrent.TimeUnit;
22
23 import org.apache.hadoop.classification.InterfaceAudience;
24 import org.apache.hadoop.hbase.util.RetryCounter.ExponentialBackoffPolicy;
25 import org.apache.hadoop.hbase.util.RetryCounter.RetryConfig;
26
27 @InterfaceAudience.Private
28 public class RetryCounterFactory {
29 private final RetryConfig retryConfig;
30
31 public RetryCounterFactory(int maxAttempts, int sleepIntervalMillis) {
32 this(new RetryConfig(
33 maxAttempts,
34 sleepIntervalMillis,
35 -1,
36 TimeUnit.MILLISECONDS,
37 new ExponentialBackoffPolicy()));
38 }
39
40 public RetryCounterFactory(RetryConfig retryConfig) {
41 this.retryConfig = retryConfig;
42 }
43
44 public RetryCounter create() {
45 return new RetryCounter(retryConfig);
46 }
47 }