@Override
            public void run() {
                // Make sure the notify task only fire to current phase.
                if (phase == ingestPhase.get() && !thread.isInterrupted() && thread.isInterrupValid()) {
                    thread.interrupt();
                }
            }
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