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

AsyncDispatcher.setDrainEventsOnStop介绍

暂无

代码示例

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

public void setDrainEventsOnStop() {
 for (AsyncDispatcher dispatcher : dispatchers) {
  dispatcher.setDrainEventsOnStop();
 }
}

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

public void setDrainEventsOnStop() {
 for (AsyncDispatcher dispatcher : dispatchers) {
  dispatcher.setDrainEventsOnStop();
 }
}

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

public void setDrainEventsOnStop() {
 for (AsyncDispatcher dispatcher : dispatchers) {
  dispatcher.setDrainEventsOnStop();
 }
}

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

public void setDrainEventsOnStop() {
 for (AsyncDispatcher dispatcher : dispatchers) {
  dispatcher.setDrainEventsOnStop();
 }
}

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

public void setDrainEventsOnStop() {
 for (AsyncDispatcher dispatcher : dispatchers) {
  dispatcher.setDrainEventsOnStop();
 }
}

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

public void setDrainEventsOnStop() {
 for (AsyncDispatcher dispatcher : dispatchers) {
  dispatcher.setDrainEventsOnStop();
 }
}

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

protected void initDispatcher(Configuration conf) {
 // create async handler
 dispatcher = new AsyncDispatcher("NodeLabelManager dispatcher");
 AsyncDispatcher asyncDispatcher = (AsyncDispatcher) dispatcher;
 asyncDispatcher.init(conf);
 asyncDispatcher.setDrainEventsOnStop();
}

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

protected void initDispatcher(Configuration conf) {
 // create async handler
 dispatcher = new AsyncDispatcher("AttributeNodeLabelsManager dispatcher");
 AsyncDispatcher asyncDispatcher = (AsyncDispatcher) dispatcher;
 asyncDispatcher.init(conf);
 asyncDispatcher.setDrainEventsOnStop();
}

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

protected void initDispatcher(Configuration conf) {
 // create async handler
 dispatcher = new AsyncDispatcher();
 AsyncDispatcher asyncDispatcher = (AsyncDispatcher) dispatcher;
 asyncDispatcher.init(conf);
 asyncDispatcher.setDrainEventsOnStop();
}

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

protected void initDispatcher(Configuration conf) {
 // create async handler
 dispatcher = new AsyncDispatcher();
 AsyncDispatcher asyncDispatcher = (AsyncDispatcher) dispatcher;
 asyncDispatcher.init(conf);
 asyncDispatcher.setDrainEventsOnStop();
}

代码示例来源：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: 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.hadoop/hadoop-mapreduce-client-app

new ForwardingEventHandler();
atsEventDispatcher.register(EventType.class, timelineEventHandler);
atsEventDispatcher.setDrainEventsOnStop();
atsEventDispatcher.init(conf);