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

AsyncDispatcher.<init>介绍

[英]Set a name for this dispatcher thread.
[中]设置此调度程序线程的名称。

代码示例

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

public QueryMasterTask(QueryMaster.QueryMasterContext queryMasterContext,
            QueryId queryId, Session session, QueryContext queryContext,
            String jsonExpr,
            NodeResource allocation) {
 this(queryMasterContext, queryId, session, queryContext, jsonExpr, allocation, new AsyncDispatcher());
}

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

/**
 * Unit test friendly.
 */
protected AsyncDispatcher createNMDispatcher() {
 return new AsyncDispatcher("NM Event dispatcher");
}

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

public QueryMasterTask(QueryMaster.QueryMasterContext queryMasterContext,
            QueryId queryId, Session session, QueryContext queryContext,
            String jsonExpr,
            NodeResource allocation) {
 this(queryMasterContext, queryId, session, queryContext, jsonExpr, allocation, new AsyncDispatcher());
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-mapreduce-client-app

protected Dispatcher createDispatcher() {
 return new AsyncDispatcher();
}

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

protected AsyncDispatcher createDispatcher() {
 return new AsyncDispatcher("RM ApplicationHistory dispatcher");
}

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

protected AsyncDispatcher createDispatcher() {
  return new AsyncDispatcher("RM Timeline dispatcher");
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-mapreduce-client-app

protected AsyncDispatcher createDispatcher() {
 return new AsyncDispatcher("Job ATS Event Dispatcher");
}

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

protected Dispatcher createDispatcher() {
 return new AsyncDispatcher();
}

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

protected AsyncDispatcher createDispatcher() {
 return new AsyncDispatcher();
}

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

protected AsyncDispatcher createDispatcher() {
 return new AsyncDispatcher();
}

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

protected AsyncDispatcher createDispatcher() {
 return new AsyncDispatcher("NM Timeline dispatcher");
}

代码示例来源：origin: org.apache.hadoop/hadoop-mapreduce-client-app

protected Dispatcher createDispatcher() {
 return new AsyncDispatcher();
}

代码示例来源：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: 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: 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: 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: 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: 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 {
 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);
}