We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 18cfe1a commit 72df580Copy full SHA for 72df580
1 file changed
src/main/java/io/goboolean/streams/streams/AggregateTransformer.java
@@ -36,7 +36,7 @@ public OneSec(String storeName) {
36
storeName,
37
new TimeTruncationer.FiveSecTruncationer(),
38
Duration.ofSeconds(1),
39
- null,
+ null
40
/*
41
GlobalOpenTelemetry.getMeterProvider()
42
.get("fetch-system.streams")
@@ -53,7 +53,7 @@ public FiveSec(String storeName) {
53
54
new TimeTruncationer.OneMinTruncationer(),
55
Duration.ofSeconds(5),
56
57
58
59
@@ -70,7 +70,7 @@ public OneMin(String storeName) {
70
71
new TimeTruncationer.FiveMinTruncationer(),
72
Duration.ofSeconds(10),
73
74
75
76
0 commit comments