import org.apache.hadoop.yarn.server.nodemanager.containermanager.application.ApplicationInitedEvent; //导入依赖的package包/类
/**
 * Handle event received the first time any container is scheduled
 * by a given application.
 */
@SuppressWarnings("unchecked")
private void handleInitApplicationResources(Application app) {
  // 0) Create application tracking structs
  String userName = app.getUser();
  privateRsrc.putIfAbsent(userName, new LocalResourcesTrackerImpl(userName,
      null, dispatcher, true, super.getConfig(), stateStore));
  String appIdStr = ConverterUtils.toString(app.getAppId());
  appRsrc.putIfAbsent(appIdStr, new LocalResourcesTrackerImpl(app.getUser(),
      app.getAppId(), dispatcher, false, super.getConfig(), stateStore));
  // 1) Signal container init
  //
  // This is handled by the ApplicationImpl state machine and allows
  // containers to proceed with launching.
  dispatcher.getEventHandler().handle(new ApplicationInitedEvent(
        app.getAppId()));
}
 

import org.apache.hadoop.yarn.server.nodemanager.containermanager.application.ApplicationInitedEvent; //导入依赖的package包/类
/**
 * Handle event received the first time any container is scheduled
 * by a given application.
 */
@SuppressWarnings("unchecked")
private void handleInitApplicationResources(Application app) {
  // 0) Create application tracking structs
  String userName = app.getUser();
  privateRsrc.putIfAbsent(userName, new LocalResourcesTrackerImpl(userName,
      null, dispatcher, true, super.getConfig(), stateStore, dirsHandler));
  String appIdStr = app.getAppId().toString();
  appRsrc.putIfAbsent(appIdStr, new LocalResourcesTrackerImpl(app.getUser(),
      app.getAppId(), dispatcher, false, super.getConfig(), stateStore,
      dirsHandler));
  // 1) Signal container init
  //
  // This is handled by the ApplicationImpl state machine and allows
  // containers to proceed with launching.
  dispatcher.getEventHandler().handle(new ApplicationInitedEvent(
        app.getAppId()));
}
 

import org.apache.hadoop.yarn.server.nodemanager.containermanager.application.ApplicationInitedEvent; //导入依赖的package包/类
@Override
@SuppressWarnings("unchecked")
protected ResourceLocalizationService createResourceLocalizationService(
    ContainerExecutor exec, DeletionService deletionContext, Context context) {
  return new ResourceLocalizationService(super.dispatcher, exec,
      deletionContext, super.dirsHandler, context) {
    @Override
    public void handle(LocalizationEvent event) {
      switch (event.getType()) {
      case INIT_APPLICATION_RESOURCES:
        Application app =
            ((ApplicationLocalizationEvent) event).getApplication();
        // Simulate event from ApplicationLocalization.
        dispatcher.getEventHandler().handle(new ApplicationInitedEvent(
              app.getAppId()));
        break;
      case INIT_CONTAINER_RESOURCES:
        ContainerLocalizationRequestEvent rsrcReqs =
          (ContainerLocalizationRequestEvent) event;
        // simulate localization of all requested resources
          for (Collection<LocalResourceRequest> rc : rsrcReqs
              .getRequestedResources().values()) {
            for (LocalResourceRequest req : rc) {
              LOG.info("DEBUG: " + req + ":"
                  + rsrcReqs.getContainer().getContainerId());
              dispatcher.getEventHandler().handle(
                  new ContainerResourceLocalizedEvent(rsrcReqs.getContainer()
                      .getContainerId(), req, new Path("file:///local"
                      + req.getPath().toUri().getPath())));
            }
          }
        break;
      case CLEANUP_CONTAINER_RESOURCES:
        Container container =
            ((ContainerLocalizationEvent) event).getContainer();
        // TODO: delete the container dir
        this.dispatcher.getEventHandler().handle(
            new ContainerEvent(container.getContainerId(),
                ContainerEventType.CONTAINER_RESOURCES_CLEANEDUP));
        break;
      case DESTROY_APPLICATION_RESOURCES:
        Application application =
          ((ApplicationLocalizationEvent) event).getApplication();

        // decrement reference counts of all resources associated with this
        // app
        this.dispatcher.getEventHandler().handle(
            new ApplicationEvent(application.getAppId(),
                ApplicationEventType.APPLICATION_RESOURCES_CLEANEDUP));
        break;
      default:
        fail("Unexpected event: " + event.getType());
      }
    }
  };
}
 

import org.apache.hadoop.yarn.server.nodemanager.containermanager.application.ApplicationInitedEvent; //导入依赖的package包/类
@Override
@SuppressWarnings("unchecked")
protected ResourceLocalizationService createResourceLocalizationService(
    ContainerExecutor exec, DeletionService deletionContext) {
  return new ResourceLocalizationService(super.dispatcher, exec,
      deletionContext, super.dirsHandler) {
    @Override
    public void handle(LocalizationEvent event) {
      switch (event.getType()) {
      case INIT_APPLICATION_RESOURCES:
        Application app =
            ((ApplicationLocalizationEvent) event).getApplication();
        // Simulate event from ApplicationLocalization.
        dispatcher.getEventHandler().handle(new ApplicationInitedEvent(
              app.getAppId()));
        break;
      case INIT_CONTAINER_RESOURCES:
        ContainerLocalizationRequestEvent rsrcReqs =
          (ContainerLocalizationRequestEvent) event;
        // simulate localization of all requested resources
          for (Collection<LocalResourceRequest> rc : rsrcReqs
              .getRequestedResources().values()) {
            for (LocalResourceRequest req : rc) {
              LOG.info("DEBUG: " + req + ":"
                  + rsrcReqs.getContainer().getContainerId());
              dispatcher.getEventHandler().handle(
                  new ContainerResourceLocalizedEvent(rsrcReqs.getContainer()
                      .getContainerId(), req, new Path("file:///local"
                      + req.getPath().toUri().getPath())));
            }
          }
        break;
      case CLEANUP_CONTAINER_RESOURCES:
        Container container =
            ((ContainerLocalizationEvent) event).getContainer();
        // TODO: delete the container dir
        this.dispatcher.getEventHandler().handle(
            new ContainerEvent(container.getContainerId(),
                ContainerEventType.CONTAINER_RESOURCES_CLEANEDUP));
        break;
      case DESTROY_APPLICATION_RESOURCES:
        Application application =
          ((ApplicationLocalizationEvent) event).getApplication();

        // decrement reference counts of all resources associated with this
        // app
        this.dispatcher.getEventHandler().handle(
            new ApplicationEvent(application.getAppId(),
                ApplicationEventType.APPLICATION_RESOURCES_CLEANEDUP));
        break;
      default:
        fail("Unexpected event: " + event.getType());
      }
    }
  };
}