From b72a70522b8a6d8c9a123eee57828b0012daa55f Mon Sep 17 00:00:00 2001 From: Charles Allen Date: Fri, 19 Jun 2015 16:47:41 -0700 Subject: [PATCH] Add basic ConciseComplementBenchmark for testing concise complements --- benchmarks/pom.xml | 7 +++ .../benchmark/ConciseComplementBenchmark.java | 52 +++++++++++++++++++ 2 files changed, 59 insertions(+) create mode 100644 benchmarks/src/main/java/io/druid/benchmark/ConciseComplementBenchmark.java diff --git a/benchmarks/pom.xml b/benchmarks/pom.xml index 74304b0f73b..8ea1cc33a30 100644 --- a/benchmarks/pom.xml +++ b/benchmarks/pom.xml @@ -52,6 +52,13 @@ druid-processing ${project.parent.version} + diff --git a/benchmarks/src/main/java/io/druid/benchmark/ConciseComplementBenchmark.java b/benchmarks/src/main/java/io/druid/benchmark/ConciseComplementBenchmark.java new file mode 100644 index 00000000000..944c59f03c8 --- /dev/null +++ b/benchmarks/src/main/java/io/druid/benchmark/ConciseComplementBenchmark.java @@ -0,0 +1,52 @@ +/* + * Licensed to Metamarkets Group Inc. (Metamarkets) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. Metamarkets licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ + +package io.druid.benchmark; + + +import it.uniroma3.mat.extendedset.intset.ImmutableConciseSet; +import org.openjdk.jmh.annotations.Benchmark; +import org.openjdk.jmh.annotations.BenchmarkMode; +import org.openjdk.jmh.annotations.Mode; +import org.openjdk.jmh.annotations.OutputTimeUnit; +import org.openjdk.jmh.annotations.Param; +import org.openjdk.jmh.annotations.Scope; +import org.openjdk.jmh.annotations.State; +import org.openjdk.jmh.infra.Blackhole; + +import java.util.concurrent.TimeUnit; + +@State(Scope.Benchmark) +public class ConciseComplementBenchmark +{ + + // Number of rows to read, the test will read random rows + @Param({"1000", "10000", "100000", "1000000", "1000000"}) + int emptyRows; + + @Benchmark + @BenchmarkMode(Mode.AverageTime) + @OutputTimeUnit(TimeUnit.MICROSECONDS) + public void uncompressed(Blackhole blackhole) + { + final ImmutableConciseSet set = ImmutableConciseSet.complement(null, emptyRows); + blackhole.consume(set); + assert (emptyRows == set.size()); + } +}