Skip to content

Commit 9d52fa8

Browse files
authored
Chore: small cosmetic 🎨 (#50)
1 parent 7f845b7 commit 9d52fa8

File tree

2 files changed

+4
-0
lines changed

2 files changed

+4
-0
lines changed

plugin/src/main/java/dev/regadas/trino/pubsub/listener/metrics/DecayRatio.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,10 @@
55
import io.airlift.stats.DecayCounter;
66
import java.util.List;
77
import java.util.function.Function;
8+
import javax.annotation.concurrent.ThreadSafe;
89
import org.weakref.jmx.Managed;
910

11+
@ThreadSafe
1012
public final class DecayRatio {
1113
private final DecayCounter numeratorCounter;
1214
private final List<DecayCounter> denominatorCounters;

plugin/src/main/java/dev/regadas/trino/pubsub/listener/metrics/RatioStat.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,9 +6,11 @@
66
import io.airlift.stats.DecayCounter;
77
import java.util.List;
88
import java.util.function.Function;
9+
import javax.annotation.concurrent.ThreadSafe;
910
import org.weakref.jmx.Managed;
1011
import org.weakref.jmx.Nested;
1112

13+
@ThreadSafe
1214
public class RatioStat {
1315
private final CounterStat numeratorCounter;
1416
private final List<CounterStat> denominatorCounters;

0 commit comments

Comments
 (0)