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, INITED, instanceStatus, jobInstanceInfo, killed, serialNum, SERVER_DISCOVERY, statusHandler, taskIdGenerator, taskStatusMap

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
protected void	checkProcessor()
void	destroyContainerPool()
void	killInstance(String reason)
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, convert2StartContainerRequest, convert2StartContainerRequest, getActorContext, getAliveCheckWorkerSet, getInstanceStatus, getJobInstanceInfo, getJobInstanceProgress, getLocalContainerRouterPath, getLocalJobInstanceRouterPath, getLocalTaskRouterPath, getLocalWorkerIdAddr, getSerialNum, init, isInited, isJobInstanceFinished, isKilled, killTask, postFinish, 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

killInstance

public void killInstance(String reason)

覆盖:

killInstance 在类中 TaskMaster

destroyContainerPool

public void destroyContainerPool()

指定者:

destroyContainerPool 在类中 TaskMaster

checkProcessor

protected void checkProcessor()
                       throws Exception

覆盖:

checkProcessor 在类中 TaskMaster

抛出:

Exception