public synchronized boolean start() {
        if (state == State.CLOSE || setting == null) {
            return false;
        }
        if (state == State.RECOVER || state == State.RUN) {
            return true;
        }

        logger.info("Starting realtime table. [table: {}]", tableName);

        state = containsRecoverRTSG() ? State.RECOVER : State.RUN;

        safeInterruptIngest();
        startIngest();

        return true;
    }
Start to ingest evnets from datasource.
indexr-segment/src/main/java/io/indexr/segment/rt/RealtimeTable.java