Increase build and probe table in join benchmarks
Build table increased 10 times so that it is less likely to fit
into CPU cache.
@@ -54,6 +54,7 @@ import static io.airlift.units.DataSize.Unit.GIGABYTE;
import static java.lang.String.format;
import static java.util.concurrent.Executors.newCachedThreadPool;
import static java.util.concurrent.TimeUnit.MILLISECONDS;
+import static java.util.concurrent.TimeUnit.SECONDS;
import static org.openjdk.jmh.annotations.Mode.AverageTime;
import static org.openjdk.jmh.annotations.Scope.Thread;
@@ -63,7 +64,7 @@ import static org.openjdk.jmh.annotations.Scope.Thread;
@BenchmarkMode(AverageTime)
@Fork(3)
@Warmup(iterations = 5)
-@Measurement(iterations = 20)
+@Measurement(iterations = 10, time = 2, timeUnit = SECONDS)
public class BenchmarkHashBuildAndJoinOperators
{
private static final int HASH_BUILD_OPERATOR_ID = 1;
@@ -75,7 +76,7 @@ public class BenchmarkHashBuildAndJoinOperators
public static class BuildContext
{
protected static final int ROWS_PER_PAGE = 1024;
- protected static final int BUILD_ROWS_NUMBER = 700_000;
+ protected static final int BUILD_ROWS_NUMBER = 8_000_000;
@Param({"varchar", "bigint", "all"})
protected String hashColumns;
@@ -161,7 +162,7 @@ public class BenchmarkHashBuildAndJoinOperators
public static class JoinContext
extends BuildContext
{
- protected static final int PROBE_ROWS_NUMBER = 700_000;
+ protected static final int PROBE_ROWS_NUMBER = 1_400_000;
@Param({"0.1", "1", "2"})
protected double matchRate;
