@Override
                public long run() {
                    Long nextPeriod = Try.on(
                            RealtimeTable.this::ingest,
                            1, logger,
                            String.format("Ingest failed. [table: %s]", tableName));
                    return nextPeriod == null ? ingestRetryPeriod : nextPeriod;
                }
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