private void registerFoundAttempt(AttemptPathIdentifier pathIdentifier, Path indexFile, Path dataFile) {
    FoundPathInfo pathInfo = foundAttempts.get(pathIdentifier);
    if (pathInfo == null) {
      pathInfo = new FoundPathInfo(indexFile, dataFile);
      foundAttempts.put(pathIdentifier, pathInfo);
    }
    if (pathInfo.isComplete()) {
      // Inform the shuffle handler
      listener.registerAttemptDirs(pathIdentifier,
          new ShuffleHandler.AttemptPathInfo(new org.apache.hadoop.fs.Path(indexFile.toUri()),
              new org.apache.hadoop.fs.Path(dataFile.toUri())));
      // Cancel existing watches
      cancelWatchesForAttempt(pathIdentifier);
      // Cleanup structures
      foundAttempts.remove(pathIdentifier);
    }
  }
Invoke when a pathIdentifier has been found, or is no longer of interest
@param pathIdentifier
llap-server/src/java/org/apache/hadoop/hive/llap/shufflehandler/DirWatcher.java