@Override
    public synchronized void close() {
        if (state == State.CLOSE) {
            return;
        }
        logger.info("Closing realtime table. [table: {}]", tableName);
        state = State.CLOSE;

        if (setting != null) {
            Try.on(setting.fetcher::close, logger);
        }
        //safeInterruptIngest();
    }
Close this realtime table. Job is done.
This method only called before process exit.
indexr-segment/src/main/java/io/indexr/segment/rt/RealtimeTable.java