com.alibaba.schedulerx.worker.master

类 BroadcastTaskMaster

java.lang.Object

com.alibaba.schedulerx.worker.master.TaskMaster

com.alibaba.schedulerx.worker.master.BroadcastTaskMaster

public class BroadcastTaskMaster
extends TaskMaster

作者:

xiaomeng.hxm

字段概要

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

aliveCheckWorkerSet, INITED, instanceStatus, jobInstanceInfo, serialNum, SERVER_DISCOVERY, statusHandler, taskIdGenerator, taskStatusMap

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
protected void	checkProcessor()
void	clear()
void	destroyContainerPool()
String	getJobInstanceProgress()
Map<String,com.alibaba.schedulerx.common.domain.WorkerProgressCounter>	getWorkerProgressMap() Getter method for property workerProgressMap.
protected void	init()
void	killInstance(String reason)
ProcessResult	postFinish(long jobInstanceId)
void	submitInstance(com.alibaba.schedulerx.common.domain.JobInstanceInfo info)
void	updateTaskStatus(com.alibaba.schedulerx.protocol.Worker.ContainerReportTaskStatusRequest request)

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

aquireSerialNum, aquireTaskId, batchUpdateTaskStatus, convert2StartContainerRequest, convert2StartContainerRequest, convert2StartContainerRequest, getActorContext, getAliveCheckWorkerSet, getInstanceStatus, getJobInstanceInfo, getLocalContainerRouterPath, getLocalJobInstanceRouterPath, getLocalTaskRouterPath, getLocalWorkerIdAddr, getSerialNum, isInited, isJobInstanceFinished, isKilled, killTask, retryTasks, setInstanceStatus, stop, updateNewInstanceStatus, updateNewInstanceStatus

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

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

构造器详细资料

BroadcastTaskMaster

public BroadcastTaskMaster(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)

指定者:

submitInstance 在类中 TaskMaster

killInstance

public void killInstance(String reason)

覆盖:

killInstance 在类中 TaskMaster

destroyContainerPool

public void destroyContainerPool()

指定者:

destroyContainerPool 在类中 TaskMaster

updateTaskStatus

public void updateTaskStatus(com.alibaba.schedulerx.protocol.Worker.ContainerReportTaskStatusRequest request)

覆盖:

updateTaskStatus 在类中 TaskMaster

getJobInstanceProgress

public String getJobInstanceProgress()

覆盖:

getJobInstanceProgress 在类中 TaskMaster

init

protected void init()

覆盖:

init 在类中 TaskMaster

getWorkerProgressMap

public Map<String,com.alibaba.schedulerx.common.domain.WorkerProgressCounter> getWorkerProgressMap()

Getter method for property workerProgressMap.

返回:

property value of workerProgressMap

checkProcessor

protected void checkProcessor()
                       throws Exception

覆盖:

checkProcessor 在类中 TaskMaster

抛出:

Exception

postFinish

public ProcessResult postFinish(long jobInstanceId)

覆盖:

postFinish 在类中 TaskMaster

clear

public void clear()

覆盖:

clear 在类中 TaskMaster