Sped up benchmarks (knative-extensions#3401)

Signed-off-by: Calum Murray <cmurray@redhat.com>
Leo6Leo · Oct 17, 2023 · 4168215 · 4168215
1 parent 204be08
commit 4168215
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 5 deletions.
diff --git a/...ain/java/dev/knative/eventing/kafka/broker/dispatcher/impl/filter/AllFilterBenchmark.java b/...ain/java/dev/knative/eventing/kafka/broker/dispatcher/impl/filter/AllFilterBenchmark.java
@@ -27,7 +27,7 @@
 
 public class AllFilterBenchmark {
     public static ExactFilter makeExactFilter() {
-        return new ExactFilter(Map.of("id", "com.github.pull.create"));
+        return new ExactFilter(Map.of("type", "com.github.pull.create"));
     }
 
     public static PrefixFilter makePrefixFilter() {

diff --git a/...ain/java/dev/knative/eventing/kafka/broker/dispatcher/impl/filter/AnyFilterBenchmark.java b/...ain/java/dev/knative/eventing/kafka/broker/dispatcher/impl/filter/AnyFilterBenchmark.java
@@ -33,7 +33,7 @@ public static CloudEvent event() {
     }
 
     public static ExactFilter makeExactFilter() {
-        return new ExactFilter(Map.of("id", "com.github.pull.create"));
+        return new ExactFilter(Map.of("type", "com.github.pull.create"));
     }
 
     public static PrefixFilter makePrefixFilter() {

diff --git a/...c/main/java/dev/knative/eventing/kafka/broker/dispatcher/impl/filter/FilterBenchmark.java b/...c/main/java/dev/knative/eventing/kafka/broker/dispatcher/impl/filter/FilterBenchmark.java
@@ -22,20 +22,22 @@
 import org.openjdk.jmh.annotations.*;
 import org.openjdk.jmh.infra.Blackhole;
 
-@BenchmarkMode(Mode.All)
+@BenchmarkMode(Mode.Throughput)
 @Fork(1)
 @State(Scope.Thread)
+@Measurement(iterations = 3, time = 10)
+@Warmup(iterations = 3, time = 5)
 @OutputTimeUnit(TimeUnit.MICROSECONDS)
 public abstract class FilterBenchmark {
     Filter filter;
     CloudEvent cloudEvent;
 
-    @Setup
+    @Setup(Level.Trial)
     public void setupFilter() {
         this.filter = createFilter();
     }
 
-    @Setup
+    @Setup(Level.Trial)
     public void setupCloudEvent() {
         this.cloudEvent = createEvent();
     }