private void cleanupDir(String dir, long deleteDelay) {
    LOG.info("Scheduling deletion of {} after {} seconds", dir, deleteDelay);
    executorService.schedule(new FileCleanerCallable(dir), deleteDelay, TimeUnit.SECONDS);
  }
Register an update to a source within an executing dag
@param queryIdentifier
@param sourceName
@param sourceState
llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/QueryTracker.java