Class AbstractCairoTest

core/src/test/java/io/questdb/test/AbstractCairoTest.java:124–1192

import java.util.concurrent.TimeUnit;

@SuppressWarnings("ClassEscapesDefinedScope")
public abstract class AbstractCairoTest extends AbstractTest {

    public static final int DEFAULT_SPIN_LOCK_TIMEOUT = 5000;
    protected static final Log LOG = LogFactory.getLog(AbstractCairoTest.class);
    protected static final String TIMESTAMP_NS_TYPE_NAME = "TIMESTAMP_NS";
    protected static final PlanSink planSink = new TextPlanSink();
    protected static final StringSink sink = new StringSink();
    private static final long[] SNAPSHOT = new long[MemoryTag.SIZE];
    public static String exportRoot = null;
    public static StaticOverrides staticOverrides = new StaticOverrides();
    protected static BindVariableService bindVariableService;
    protected static NetworkSqlExecutionCircuitBreaker circuitBreaker;
    protected static SqlExecutionCircuitBreakerConfiguration circuitBreakerConfiguration;
    protected static CairoConfiguration configuration;
    protected static TestCairoConfigurationFactory configurationFactory;
    protected static long currentMicros = -1;
    protected static final MicrosecondClock defaultMicrosecondClock = () -> currentMicros != -1 ? currentMicros : MicrosecondClockImpl.INSTANCE.getTicks();
    protected static MicrosecondClock testMicrosClock = defaultMicrosecondClock;
    protected static final NanosecondClock defaultNanosecondClock = () -> currentMicros != -1 ? currentMicros * 1000L : NanosecondClockImpl.INSTANCE.getTicks();
    protected static NanosecondClock testNanoClock = defaultNanosecondClock;
    protected static CairoEngine engine;
    protected static TestCairoEngineFactory engineFactory;
    protected static FactoryProvider factoryProvider;
    protected static FilesFacade ff;
    protected static String inputRoot = null;
    protected static String inputWorkRoot = null;
    protected static IOURingFacade ioURingFacade = IOURingFacadeImpl.INSTANCE;
    protected static MessageBus messageBus;
    protected static QuestDBTestNode node1;
    protected static ObjList<QuestDBTestNode> nodes = new ObjList<>();
    protected static SecurityContext securityContext;
    protected static long spinLockTimeout = DEFAULT_SPIN_LOCK_TIMEOUT;
    protected static SqlExecutionContext sqlExecutionContext;
    static boolean[] FACTORY_TAGS = new boolean[MemoryTag.SIZE];
    private static long fdReuseCount;
    private static long memoryUsage = -1;
    private static long mmapReuseCount;
    @Rule
    public final TestWatcher flushLogsOnFailure = new TestWatcher() {
        @Override
        protected void failed(Throwable e, Description description) {
            LogFactory.getInstance().flushJobs();
        }
    };
    @Rule
    public Timeout timeout = Timeout.builder()
            .withTimeout(20 * 60 * 1000, TimeUnit.MILLISECONDS)
            .withLookingForStuckThread(true)
            .build();

    public static void assertReader(String expected, CharSequence tableName) {
        try (TableReader reader = engine.getReader(engine.verifyTableName(tableName))) {
            TestUtils.assertReader(expected, reader, sink);
        }
    }

    public static void assertVariableColumns(RecordCursorFactory factory, SqlExecutionContext executionContext) throws SqlException {