import org.apache.hadoop.yarn.server.nodemanager.containermanager.localizer.LocalResourceRequest; //导入依赖的package包/类
@SuppressWarnings("unchecked") // dispatcher not typed
public void cleanup() {
  Map<LocalResourceVisibility, Collection<LocalResourceRequest>> rsrc =
    new HashMap<LocalResourceVisibility, 
                Collection<LocalResourceRequest>>();
  if (!publicRsrcs.isEmpty()) {
    rsrc.put(LocalResourceVisibility.PUBLIC, publicRsrcs);
  }
  if (!privateRsrcs.isEmpty()) {
    rsrc.put(LocalResourceVisibility.PRIVATE, privateRsrcs);
  }
  if (!appRsrcs.isEmpty()) {
    rsrc.put(LocalResourceVisibility.APPLICATION, appRsrcs);
  }
  dispatcher.getEventHandler().handle(
      new ContainerLocalizationCleanupEvent(this, rsrc));
}
 

import org.apache.hadoop.yarn.server.nodemanager.containermanager.localizer.LocalResourceRequest; //导入依赖的package包/类
@Override
public boolean matches(Object o) {
  if (!(o instanceof ContainerLocalizationCleanupEvent)) {
    return false;
  }
  ContainerLocalizationCleanupEvent evt =
      (ContainerLocalizationCleanupEvent) o;
  final HashSet<LocalResourceRequest> expected =
      new HashSet<LocalResourceRequest>(resources);
  for (Collection<LocalResourceRequest> rc : evt.getResources().values()) {
    for (LocalResourceRequest rsrc : rc) {
      if (!expected.remove(rsrc)) {
        return false;
      }
    }
  }
  return expected.isEmpty();
}
 

import org.apache.hadoop.yarn.server.nodemanager.containermanager.localizer.LocalResourceRequest; //导入依赖的package包/类
public Map<Path, List<String>> doLocalizeResources(
    boolean checkLocalizingState, int skipRsrcCount)
    throws URISyntaxException {
  Path cache = new Path("file:///cache");
  Map<Path, List<String>> localPaths =
      new HashMap<Path, List<String>>();
  int counter = 0;
  for (Entry<String, LocalResource> rsrc : localResources.entrySet()) {
    if (counter++ < skipRsrcCount) {
      continue;
    }
    if (checkLocalizingState) {
      assertEquals(ContainerState.LOCALIZING, c.getContainerState());
    }
    LocalResourceRequest req = new LocalResourceRequest(rsrc.getValue());
    Path p = new Path(cache, rsrc.getKey());
    localPaths.put(p, Arrays.asList(rsrc.getKey()));
    // rsrc copied to p
    c.handle(new ContainerResourceLocalizedEvent(c.getContainerId(),
             req, p));
  }
  drainDispatcherEvents();
  return localPaths;
}
 

import org.apache.hadoop.yarn.server.nodemanager.containermanager.localizer.LocalResourceRequest; //导入依赖的package包/类
@Override
public void handle(SharedCacheUploadEvent event) {
  if (enabled) {
    Map<LocalResourceRequest,Path> resources = event.getResources();
    for (Map.Entry<LocalResourceRequest,Path> e: resources.entrySet()) {
      SharedCacheUploader uploader =
          new SharedCacheUploader(e.getKey(), e.getValue(), event.getUser(),
              getConfig(), scmClient, fs, localFs);
      // fire off an upload task
      uploaderPool.submit(uploader);
    }
  }
}
 

import org.apache.hadoop.yarn.server.nodemanager.containermanager.localizer.LocalResourceRequest; //导入依赖的package包/类
public SharedCacheUploadEvent(Map<LocalResourceRequest,Path> resources,
    ContainerLaunchContext context, String user,
    SharedCacheUploadEventType eventType) {
  super(eventType);
  this.resources = resources;
  this.context = context;
  this.user = user;
}
 

import org.apache.hadoop.yarn.server.nodemanager.containermanager.localizer.LocalResourceRequest; //导入依赖的package包/类
static void checkNotEqual(LocalResourceRequest a, LocalResourceRequest b) {
  assertFalse(a.equals(b));
  assertFalse(b.equals(a));
  assertFalse(a.hashCode() == b.hashCode());
  assertFalse(0 == a.compareTo(b));
  assertFalse(0 == b.compareTo(a));
}
 

import org.apache.hadoop.yarn.server.nodemanager.containermanager.localizer.LocalResourceRequest; //导入依赖的package包/类
ResourcesReleasedMatcher(Map<String, LocalResource> allResources,
    EnumSet<LocalResourceVisibility> vis) throws URISyntaxException {
  for (Entry<String, LocalResource> e : allResources.entrySet()) {
    if (vis.contains(e.getValue().getVisibility())) {
      resources.add(new LocalResourceRequest(e.getValue()));
    }
  }
}