org.apache.hadoop.yarn.event.AsyncDispatcher.register()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(11.3k)|赞(0)|评价(0)|浏览(69)

本文整理了Java中org.apache.hadoop.yarn.event.AsyncDispatcher.register()方法的一些代码示例，展示了AsyncDispatcher.register()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。AsyncDispatcher.register()方法的具体详情如下：
包路径：org.apache.hadoop.yarn.event.AsyncDispatcher
类名称：AsyncDispatcher
方法名：register

AsyncDispatcher.register介绍

暂无

代码示例

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

@Override
public void register(Class<? extends Enum> eventType, EventHandler handler) {
 for (AsyncDispatcher dispatcher : dispatchers) {
  dispatcher.register(eventType, handler);
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

@Override
public void register(Class<? extends Enum> eventType, EventHandler handler) {
 for (AsyncDispatcher dispatcher : dispatchers) {
  dispatcher.register(eventType, handler);
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

@Override
public void register(Class<? extends Enum> eventType,
  EventHandler handler) {
 for (AsyncDispatcher dispatcher : dispatchers) {
  dispatcher.register(eventType, handler);
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

@Override
public void register(Class<? extends Enum> eventType, EventHandler handler) {
 for (AsyncDispatcher dispatcher : dispatchers) {
  dispatcher.register(eventType, handler);
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-resourcemanager

@Override
public void register(Class<? extends Enum> eventType, EventHandler handler) {
 for (AsyncDispatcher dispatcher : dispatchers) {
  dispatcher.register(eventType, handler);
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-resourcemanager

@Override
public void register(Class<? extends Enum> eventType, EventHandler handler) {
 for (AsyncDispatcher dispatcher : dispatchers) {
  dispatcher.register(eventType, handler);
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-nodemanager

/**
 * Creates an instance of the service.
 *
 * @param nmContext NM context
 * @param dispatcher NM dispatcher
 */
public AMRMProxyService(Context nmContext, AsyncDispatcher dispatcher) {
 super(AMRMProxyService.class.getName());
 Preconditions.checkArgument(nmContext != null, "nmContext is null");
 Preconditions.checkArgument(dispatcher != null, "dispatcher is null");
 this.nmContext = nmContext;
 this.dispatcher = dispatcher;
 this.applPipelineMap =
   new ConcurrentHashMap<ApplicationId, RequestInterceptorChainWrapper>();
 this.dispatcher.register(ApplicationEventType.class,
   new ApplicationEventHandler());
}

代码示例来源：origin: io.hops/hadoop-yarn-server-nodemanager

/**
 * Creates an instance of the service.
 * 
 * @param nmContext
 * @param dispatcher
 */
public AMRMProxyService(Context nmContext, AsyncDispatcher dispatcher) {
 super(AMRMProxyService.class.getName());
 Preconditions.checkArgument(nmContext != null, "nmContext is null");
 Preconditions.checkArgument(dispatcher != null, "dispatcher is null");
 this.nmContext = nmContext;
 this.dispatcher = dispatcher;
 this.applPipelineMap =
   new ConcurrentHashMap<ApplicationId, RequestInterceptorChainWrapper>();
 this.dispatcher.register(ApplicationEventType.class,
   new ApplicationEventHandler());
}

代码示例来源：origin: apache/tajo

@Override
public void serviceInit(Configuration conf) throws Exception {
 systemConf = TUtil.checkTypeAndGet(conf, TajoConf.class);
 rpcParams = RpcParameterFactory.get(systemConf);
 queryTaskContext = new QueryMasterTaskContext();
 addService(dispatcher);
 dispatcher.register(StageEventType.class, new StageEventDispatcher());
 dispatcher.register(TaskEventType.class, new TaskEventDispatcher());
 dispatcher.register(TaskAttemptEventType.class, new TaskAttemptEventDispatcher());
 dispatcher.register(QueryMasterQueryCompletedEvent.EventType.class, new QueryFinishEventHandler());
 dispatcher.register(TaskSchedulerEvent.EventType.class, new TaskSchedulerDispatcher());
 dispatcher.register(LocalTaskEventType.class, new LocalTaskEventHandler());
 super.serviceInit(systemConf);
}

代码示例来源：origin: org.apache.tajo/tajo-core

@Override
public void serviceInit(Configuration conf) throws Exception {
 systemConf = TUtil.checkTypeAndGet(conf, TajoConf.class);
 rpcParams = RpcParameterFactory.get(systemConf);
 queryTaskContext = new QueryMasterTaskContext();
 addService(dispatcher);
 dispatcher.register(StageEventType.class, new StageEventDispatcher());
 dispatcher.register(TaskEventType.class, new TaskEventDispatcher());
 dispatcher.register(TaskAttemptEventType.class, new TaskAttemptEventDispatcher());
 dispatcher.register(QueryMasterQueryCompletedEvent.EventType.class, new QueryFinishEventHandler());
 dispatcher.register(TaskSchedulerEvent.EventType.class, new TaskSchedulerDispatcher());
 dispatcher.register(LocalTaskEventType.class, new LocalTaskEventHandler());
 super.serviceInit(systemConf);
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-nodemanager

@Override
public void serviceInit(Configuration conf) throws Exception {
 LogHandler logHandler =
  createLogHandler(conf, this.context, this.deletionService);
 addIfService(logHandler);
 dispatcher.register(LogHandlerEventType.class, logHandler);
 
 // add the shared cache upload service (it will do nothing if the shared
 // cache is disabled)
 SharedCacheUploadService sharedCacheUploader =
   createSharedCacheUploaderService();
 addService(sharedCacheUploader);
 dispatcher.register(SharedCacheUploadEventType.class, sharedCacheUploader);
 waitForContainersOnShutdownMillis =
   conf.getLong(YarnConfiguration.NM_SLEEP_DELAY_BEFORE_SIGKILL_MS,
     YarnConfiguration.DEFAULT_NM_SLEEP_DELAY_BEFORE_SIGKILL_MS) +
   conf.getLong(YarnConfiguration.NM_PROCESS_KILL_WAIT_MS,
     YarnConfiguration.DEFAULT_NM_PROCESS_KILL_WAIT_MS) +
   SHUTDOWN_CLEANUP_SLOP_MS;
 super.serviceInit(conf);
 recover();
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-nodemanager

@Override
public void serviceInit(Configuration conf) throws Exception {
 logHandler =
  createLogHandler(conf, this.context, this.deletionService);
 addIfService(logHandler);
 dispatcher.register(LogHandlerEventType.class, logHandler);
 
 // add the shared cache upload service (it will do nothing if the shared
 // cache is disabled)
 SharedCacheUploadService sharedCacheUploader =
   createSharedCacheUploaderService();
 addService(sharedCacheUploader);
 dispatcher.register(SharedCacheUploadEventType.class, sharedCacheUploader);
 createAMRMProxyService(conf);
 waitForContainersOnShutdownMillis =
   conf.getLong(YarnConfiguration.NM_SLEEP_DELAY_BEFORE_SIGKILL_MS,
     YarnConfiguration.DEFAULT_NM_SLEEP_DELAY_BEFORE_SIGKILL_MS) +
   conf.getLong(YarnConfiguration.NM_PROCESS_KILL_WAIT_MS,
     YarnConfiguration.DEFAULT_NM_PROCESS_KILL_WAIT_MS) +
   SHUTDOWN_CLEANUP_SLOP_MS;
 super.serviceInit(conf);
 recover();
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

@Override
protected void serviceInit(Configuration conf) throws Exception{
 // create async handler
 dispatcher = new AsyncDispatcher("RM StateStore dispatcher");
 dispatcher.init(conf);
 rmStateStoreEventHandler = new ForwardingEventHandler();
 dispatcher.register(RMStateStoreEventType.class, 
           rmStateStoreEventHandler);
 dispatcher.setDrainEventsOnStop();
 // read the base epoch value from conf
 baseEpoch = conf.getLong(YarnConfiguration.RM_EPOCH,
   YarnConfiguration.DEFAULT_RM_EPOCH);
 epochRange = conf.getLong(YarnConfiguration.RM_EPOCH_RANGE,
   YarnConfiguration.DEFAULT_RM_EPOCH_RANGE);
 initInternal(conf);
}

代码示例来源：origin: io.hops/hadoop-yarn-server-nodemanager

@Override
public void serviceInit(Configuration conf) throws Exception {
 LogHandler logHandler =
  createLogHandler(conf, this.context, this.deletionService);
 addIfService(logHandler);
 dispatcher.register(LogHandlerEventType.class, logHandler);
 
 // add the shared cache upload service (it will do nothing if the shared
 // cache is disabled)
 SharedCacheUploadService sharedCacheUploader =
   createSharedCacheUploaderService();
 addService(sharedCacheUploader);
 dispatcher.register(SharedCacheUploadEventType.class, sharedCacheUploader);
 createAMRMProxyService(conf);
 waitForContainersOnShutdownMillis =
   conf.getLong(YarnConfiguration.NM_SLEEP_DELAY_BEFORE_SIGKILL_MS,
     YarnConfiguration.DEFAULT_NM_SLEEP_DELAY_BEFORE_SIGKILL_MS) +
   conf.getLong(YarnConfiguration.NM_PROCESS_KILL_WAIT_MS,
     YarnConfiguration.DEFAULT_NM_PROCESS_KILL_WAIT_MS) +
   SHUTDOWN_CLEANUP_SLOP_MS;
 super.serviceInit(conf);
 recover();
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

@Override
protected void serviceInit(Configuration conf) throws Exception{
 // create async handler
 dispatcher = new AsyncDispatcher();
 dispatcher.init(conf);
 dispatcher.register(RMStateStoreEventType.class, 
           new ForwardingEventHandler());
 dispatcher.setDrainEventsOnStop();
 initInternal(conf);
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-resourcemanager

@Override
protected void serviceInit(Configuration conf) throws Exception{
 // create async handler
 dispatcher = new AsyncDispatcher();
 dispatcher.init(conf);
 dispatcher.register(RMStateStoreEventType.class, 
           new ForwardingEventHandler());
 dispatcher.setDrainEventsOnStop();
 initInternal(conf);
}

代码示例来源：origin: org.apache.tajo/tajo-core

@Override
public void serviceInit(Configuration conf) throws Exception {
 try {
  this.dispatcher = new AsyncDispatcher();
  addService(this.dispatcher);
  this.dispatcher.register(QueryJobEvent.Type.class, new QueryJobManagerEventHandler());
  TajoConf tajoConf = TUtil.checkTypeAndGet(conf, TajoConf.class);
  this.historyCache = new LRUMap(tajoConf.getIntVar(TajoConf.ConfVars.HISTORY_QUERY_CACHE_SIZE));
 } catch (Exception e) {
  LOG.error("Failed to init service " + getName() + " by exception " + e, e);
 }
 super.serviceInit(conf);
}

代码示例来源：origin: apache/tajo

@Override
public void serviceInit(Configuration conf) throws Exception {
 try {
  this.dispatcher = new AsyncDispatcher();
  addService(this.dispatcher);
  this.dispatcher.register(QueryJobEvent.Type.class, new QueryJobManagerEventHandler());
  TajoConf tajoConf = TUtil.checkTypeAndGet(conf, TajoConf.class);
  this.historyCache = new LRUMap(tajoConf.getIntVar(TajoConf.ConfVars.HISTORY_QUERY_CACHE_SIZE));
 } catch (Exception e) {
  LOG.error("Failed to init service " + getName() + " by exception " + e, e);
 }
 super.serviceInit(conf);
}

代码示例来源：origin: org.apache.tajo/tajo-core

@Override
public void serviceInit(Configuration conf) throws Exception {
 this.systemConf = TUtil.checkTypeAndGet(conf, TajoConf.class);
 this.manager = RpcClientManager.getInstance();
 this.rpcClientParams = RpcParameterFactory.get(this.systemConf);
 querySessionTimeout = systemConf.getIntVar(TajoConf.ConfVars.QUERY_SESSION_TIMEOUT);
 queryMasterContext = new QueryMasterContext(systemConf);
 clock = new SystemClock();
 finishedQueryMasterTasksCache = new LRUMap(systemConf.getIntVar(TajoConf.ConfVars.HISTORY_QUERY_CACHE_SIZE));
 this.dispatcher = new AsyncDispatcher();
 addIfService(dispatcher);
 globalPlanner = new GlobalPlanner(systemConf, workerContext);
 dispatcher.register(QueryStartEvent.EventType.class, new QueryStartEventHandler());
 dispatcher.register(QueryStopEvent.EventType.class, new QueryStopEventHandler());
 super.serviceInit(conf);
 LOG.info("QueryMaster inited");
}

代码示例来源：origin: apache/tajo

@Override
public void serviceInit(Configuration conf) throws Exception {
 this.systemConf = TUtil.checkTypeAndGet(conf, TajoConf.class);
 this.manager = RpcClientManager.getInstance();
 this.rpcClientParams = RpcParameterFactory.get(this.systemConf);
 querySessionTimeout = systemConf.getIntVar(TajoConf.ConfVars.QUERY_SESSION_TIMEOUT);
 queryMasterContext = new QueryMasterContext(systemConf);
 clock = new SystemClock();
 finishedQueryMasterTasksCache = new LRUMap(systemConf.getIntVar(TajoConf.ConfVars.HISTORY_QUERY_CACHE_SIZE));
 this.dispatcher = new AsyncDispatcher();
 addIfService(dispatcher);
 globalPlanner = new GlobalPlanner(systemConf, workerContext);
 dispatcher.register(QueryStartEvent.EventType.class, new QueryStartEventHandler());
 dispatcher.register(QueryStopEvent.EventType.class, new QueryStopEventHandler());
 super.serviceInit(conf);
 LOG.info("QueryMaster inited");
}

内容来源于网络，如有侵权，请联系作者删除！

AsyncDispatcher

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com