public synchronized boolean stop() {
        if (state == State.CLOSE) {
            return false;
        }
        if (state == State.STOP) {
            return true;
        }
        logger.info("Stoping realtime table and upload local realtime segments. [table: {}]", tableName);

        state = State.STOP;
        if (setting != null) {
            Try.on(setting.fetcher::close, logger);
        }
        //safeInterruptIngest();

        for (RTSGroup rtsGroup : rtsGroups.values()) {
            rtsGroup.setHandlePeriod(200);
            rtsGroup.setFastPeriod(0);
        }

        return true;
    }
Stop ingesting events into this realtime table.
indexr-segment/src/main/java/io/indexr/segment/rt/RealtimeTable.java