@Override
          public AttemptPathInfo load(AttemptPathIdentifier key) throws
              Exception {
            String base = getBaseLocation(key.jobId, key.dagId, key.user);
            String attemptBase = base + key.attemptId;
            Path indexFileName =
                lDirAlloc.getLocalPathToRead(attemptBase + "/" + INDEX_FILE_NAME, conf);
            Path mapOutputFileName =
                lDirAlloc.getLocalPathToRead(attemptBase + "/" + DATA_FILE_NAME, conf);

            LOG.debug("Loaded : " + key + " via loader");
            if (dirWatcher != null) {
              dirWatcher.attemptInfoFound(key);
            }
            return new AttemptPathInfo(indexFileName, mapOutputFileName);

          }
Unregister a specific dag

This method and registerDag must be synchronized externally to prevent races in shuffle token registration/unregistration

@param dir
@param applicationIdString
@param dagIdentifier
llap-server/src/java/org/apache/hadoop/hive/llap/shufflehandler/ShuffleHandler.java