com.alibaba.schedulerx.worker.master

类 StandaloneTaskMaster

java.lang.Object

com.alibaba.schedulerx.worker.master.TaskMaster

com.alibaba.schedulerx.worker.master.StandaloneTaskMaster

public class StandaloneTaskMaster
extends TaskMaster

作者:

xiaomeng.hxm

字段概要

从类继承的字段 com.alibaba.schedulerx.worker.master.TaskMaster

aliveCheckWorkerSet, existInvalidWorker, INITED, instanceStatus, jobInstanceInfo, jobInstanceProgress, killed, serialNum, SERVER_DISCOVERY, statusHandler, taskIdGenerator, taskStatusMap

构造器概要

构造器

构造器和说明
StandaloneTaskMaster(com.alibaba.schedulerx.common.domain.JobInstanceInfo jobInstanceInfo, akka.actor.ActorContext actorContext)

方法概要

限定符和类型	方法和说明
protected void	checkProcessor()
void	destroyContainerPool()
akka.actor.ActorSelection	getCurrentSelection()
void	killInstance(String reason)
protected String	selectWorker() 轮询获取可执行机器
void	submitInstance(com.alibaba.schedulerx.common.domain.JobInstanceInfo info) Standalone TaskMaster only submit to localhost

从类继承的方法 com.alibaba.schedulerx.worker.master.TaskMaster

aquireSerialNum, aquireTaskId, batchUpdateTaskStatus, clear, convert2StartContainerRequest, convert2StartContainerRequestBuilder, convert2StartContainerRequestBuilder, existInvalidWorker, getActorContext, getAliveCheckWorkerSet, getInstanceStatus, getJobInstanceInfo, getJobInstanceProgress, getLocalContainerRouterPath, getLocalJobInstanceRouterPath, getLocalTaskRouterPath, getLocalWorkerIdAddr, getSerialNum, init, isInited, isJobInstanceFinished, isKilled, killTask, postFinish, restJobInstanceWorkerList, retryTasks, setInstanceStatus, stop, updateNewInstanceStatus, updateNewInstanceStatus, updateTaskStatus

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

StandaloneTaskMaster

public StandaloneTaskMaster(com.alibaba.schedulerx.common.domain.JobInstanceInfo jobInstanceInfo,
                            akka.actor.ActorContext actorContext)
                     throws Exception

抛出:

Exception

方法详细资料

submitInstance

public void submitInstance(com.alibaba.schedulerx.common.domain.JobInstanceInfo info)

Standalone TaskMaster only submit to localhost

指定者:

submitInstance 在类中 TaskMaster

selectWorker

protected String selectWorker()

轮询获取可执行机器

返回:

killInstance

public void killInstance(String reason)

覆盖:

killInstance 在类中 TaskMaster

destroyContainerPool

public void destroyContainerPool()

指定者:

destroyContainerPool 在类中 TaskMaster

checkProcessor

protected void checkProcessor()
                       throws Exception

覆盖:

checkProcessor 在类中 TaskMaster

抛出:

Exception

getCurrentSelection

public akka.actor.ActorSelection getCurrentSelection()