Class PerformanceTest

core/src/test/java/io/questdb/test/PerformanceTest.java:46–232

import java.util.concurrent.TimeUnit;

public class PerformanceTest extends AbstractCairoTest {

    private static final Log LOG = LogFactory.getLog(PerformanceTest.class);
    private static final int TEST_DATA_SIZE = 1_000_000;
    private long timeoutResult;

    @Test
    public void testCairoPartitionedReaderReloadSpeed() throws Exception {
        assertMemoryLeak(() -> {
            int operations = 1_00_000 * 100;
            double speed = measureReloadSpeed(1_00_000, operations, 100000);

            // Add 10x slowdown for slow / busy build server.
            Assert.assertTrue("Total reload should be around 300 ms", TimeUnit.NANOSECONDS.toMillis((long) (operations * speed)) < 30000);
        });
    }

    @Test
    public void testCairoPerformance() throws Exception {
        assertMemoryLeak(() -> {
            int count = 10;
            long t = 0;
            long result;

            String[] symbols = {"AGK.L", "BP.L", "TLW.L", "ABF.L", "LLOY.L", "BT-A.L", "WTB.L", "RRS.L", "ADM.L", "GKN.L", "HSBA.L"};
            TableModel model = new TableModel(configuration, "quote", PartitionBy.NONE)
                    .timestamp()
                    .col("sym", ColumnType.SYMBOL)
                    .col("bid", ColumnType.DOUBLE)
                    .col("ask", ColumnType.DOUBLE)
                    .col("bidSize", ColumnType.INT)
                    .col("askSize", ColumnType.INT)
                    .col("mode", ColumnType.SYMBOL).symbolCapacity(2)
                    .col("ex", ColumnType.SYMBOL).symbolCapacity(2);
            AbstractCairoTest.create(model);

            try (TableWriter writer = newOffPoolWriter(configuration, "quote")) {
                for (int i = -count; i < count; i++) {
                    if (i == 0) {
                        t = System.nanoTime();
                    }
                    writer.truncate();
                    long timestamp = DateFormatUtils.parseUTCDate("2013-10-05T10:00:00.000Z");
                    Rnd r = new Rnd();
                    int n = symbols.length - 1;
                    for (int i1 = 0; i1 < TEST_DATA_SIZE; i1++) {
                        TableWriter.Row row = writer.newRow(timestamp);
                        row.putSym(1, symbols[Math.abs(r.nextInt() % n)]);
                        row.putDouble(2, Math.abs(r.nextDouble()));
                        row.putDouble(3, Math.abs(r.nextDouble()));
                        row.putInt(4, Math.abs(r.nextInt()));
                        row.putInt(5, Math.abs(r.nextInt()));
                        row.putSym(6, "LXE");
                        row.putSym(7, "Fast trading");
                        row.append();
                        timestamp += 1000;
                    }
                    writer.commit();