com.alibaba.schedulerx.worker.master

类 TaskMaster

java.lang.Object

com.alibaba.schedulerx.worker.master.TaskMaster

直接已知子类:

BroadcastTaskMaster, MapTaskMaster, StandaloneTaskMaster

public abstract class TaskMaster
extends Object

作者:

xiaomeng.hxm

字段概要

字段

限定符和类型	字段和说明
protected Set<String>	aliveCheckWorkerSet
protected boolean	INITED
protected com.alibaba.schedulerx.common.domain.InstanceStatus	instanceStatus
protected com.alibaba.schedulerx.common.domain.JobInstanceInfo	jobInstanceInfo
protected boolean	killed
protected AtomicLong	serialNum
protected ServerDiscovery	SERVER_DISCOVERY
protected UpdateInstanceStatusHandler	statusHandler
protected AtomicLong	taskIdGenerator
protected Map<String,com.alibaba.schedulerx.common.domain.TaskStatus>	taskStatusMap

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
long	aquireSerialNum()
protected long	aquireTaskId()
void	batchUpdateTaskStatus(com.alibaba.schedulerx.protocol.Worker.ContainerBatchReportTaskStatuesRequest request)
protected void	checkProcessor()
void	clear()
protected com.alibaba.schedulerx.protocol.Worker.MasterStartContainerRequest	convert2StartContainerRequest(com.alibaba.schedulerx.common.domain.JobInstanceInfo jobInstanceInfo, long taskId)
protected com.alibaba.schedulerx.protocol.Worker.MasterStartContainerRequest	convert2StartContainerRequest(com.alibaba.schedulerx.common.domain.JobInstanceInfo jobInstanceInfo, long taskId, String taskName, com.google.protobuf.ByteString taskBody)
protected com.alibaba.schedulerx.protocol.Worker.MasterStartContainerRequest	convert2StartContainerRequest(com.alibaba.schedulerx.common.domain.JobInstanceInfo jobInstanceInfo, long taskId, String taskName, com.google.protobuf.ByteString taskBody, boolean failover)
abstract void	destroyContainerPool()
akka.actor.ActorContext	getActorContext()
Set<String>	getAliveCheckWorkerSet() Getter method for property aliveCheckWorkerSet.
com.alibaba.schedulerx.common.domain.InstanceStatus	getInstanceStatus() Getter method for property instanceStatus.
com.alibaba.schedulerx.common.domain.JobInstanceInfo	getJobInstanceInfo() Getter method for property jobInstanceInfo.
String	getJobInstanceProgress()
String	getLocalContainerRouterPath()
String	getLocalJobInstanceRouterPath()
String	getLocalTaskRouterPath()
String	getLocalWorkerIdAddr()
long	getSerialNum()
protected void	init()
boolean	isInited()
boolean	isJobInstanceFinished()
boolean	isKilled()
void	killInstance(String reason)
void	killTask(String uniqueId, String workerId, String workerAddr)
ProcessResult	postFinish(long jobInstanceId)
void	retryTasks(List<com.alibaba.schedulerx.protocol.Server.RetryTaskEntity> taskEntities)
void	setInstanceStatus(com.alibaba.schedulerx.common.domain.InstanceStatus instanceStatus) Setter method for property instanceStatus .
void	stop()
abstract void	submitInstance(com.alibaba.schedulerx.common.domain.JobInstanceInfo jobInstanceInfo)
void	updateNewInstanceStatus(long serialNum, com.alibaba.schedulerx.common.domain.InstanceStatus newStatus, String result)
protected void	updateNewInstanceStatus(long serialNum, long jobInstanceId, com.alibaba.schedulerx.common.domain.InstanceStatus newStatus, String result)
void	updateTaskStatus(com.alibaba.schedulerx.protocol.Worker.ContainerReportTaskStatusRequest request)

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

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

字段详细资料

instanceStatus

protected volatile com.alibaba.schedulerx.common.domain.InstanceStatus instanceStatus

taskStatusMap

protected volatile Map<String,com.alibaba.schedulerx.common.domain.TaskStatus> taskStatusMap

taskIdGenerator

protected AtomicLong taskIdGenerator

jobInstanceInfo

protected final com.alibaba.schedulerx.common.domain.JobInstanceInfo jobInstanceInfo

statusHandler

protected final UpdateInstanceStatusHandler statusHandler

killed

protected volatile boolean killed

INITED

protected volatile boolean INITED

aliveCheckWorkerSet

protected Set<String> aliveCheckWorkerSet

SERVER_DISCOVERY

protected final ServerDiscovery SERVER_DISCOVERY

serialNum

protected AtomicLong serialNum

构造器详细资料

TaskMaster

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

抛出:

Exception

方法详细资料

getActorContext

public akka.actor.ActorContext getActorContext()

getLocalWorkerIdAddr

public String getLocalWorkerIdAddr()

getLocalJobInstanceRouterPath

public String getLocalJobInstanceRouterPath()

getLocalContainerRouterPath

public String getLocalContainerRouterPath()

getLocalTaskRouterPath

public String getLocalTaskRouterPath()

isJobInstanceFinished

public boolean isJobInstanceFinished()

updateTaskStatus

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

抛出:

Exception

batchUpdateTaskStatus

public void batchUpdateTaskStatus(com.alibaba.schedulerx.protocol.Worker.ContainerBatchReportTaskStatuesRequest request)
                           throws Exception

抛出:

Exception

killInstance

public void killInstance(String reason)

destroyContainerPool

public abstract void destroyContainerPool()

killTask

public void killTask(String uniqueId,
                     String workerId,
                     String workerAddr)

init

protected void init()

retryTasks

public void retryTasks(List<com.alibaba.schedulerx.protocol.Server.RetryTaskEntity> taskEntities)

submitInstance

public abstract void submitInstance(com.alibaba.schedulerx.common.domain.JobInstanceInfo jobInstanceInfo)
                             throws Exception

抛出:

Exception

aquireTaskId

protected long aquireTaskId()

getJobInstanceProgress

public String getJobInstanceProgress()

updateNewInstanceStatus

public void updateNewInstanceStatus(long serialNum,
                                    com.alibaba.schedulerx.common.domain.InstanceStatus newStatus,
                                    String result)

updateNewInstanceStatus

protected void updateNewInstanceStatus(long serialNum,
                                       long jobInstanceId,
                                       com.alibaba.schedulerx.common.domain.InstanceStatus newStatus,
                                       String result)

stop

public void stop()

clear

public void clear()

postFinish

public ProcessResult postFinish(long jobInstanceId)

convert2StartContainerRequest

protected com.alibaba.schedulerx.protocol.Worker.MasterStartContainerRequest convert2StartContainerRequest(com.alibaba.schedulerx.common.domain.JobInstanceInfo jobInstanceInfo,
                                                                                                           long taskId)

convert2StartContainerRequest

protected com.alibaba.schedulerx.protocol.Worker.MasterStartContainerRequest convert2StartContainerRequest(com.alibaba.schedulerx.common.domain.JobInstanceInfo jobInstanceInfo,
                                                                                                           long taskId,
                                                                                                           String taskName,
                                                                                                           com.google.protobuf.ByteString taskBody)

convert2StartContainerRequest

protected com.alibaba.schedulerx.protocol.Worker.MasterStartContainerRequest convert2StartContainerRequest(com.alibaba.schedulerx.common.domain.JobInstanceInfo jobInstanceInfo,
                                                                                                           long taskId,
                                                                                                           String taskName,
                                                                                                           com.google.protobuf.ByteString taskBody,
                                                                                                           boolean failover)

getInstanceStatus

public com.alibaba.schedulerx.common.domain.InstanceStatus getInstanceStatus()

Getter method for property instanceStatus.

返回:

property value of instanceStatus

setInstanceStatus

public void setInstanceStatus(com.alibaba.schedulerx.common.domain.InstanceStatus instanceStatus)

Setter method for property instanceStatus .

参数:

instanceStatus - value to be assigned to property instanceStatus

isKilled

public boolean isKilled()

getJobInstanceInfo

public com.alibaba.schedulerx.common.domain.JobInstanceInfo getJobInstanceInfo()

Getter method for property jobInstanceInfo.

返回:

property value of jobInstanceInfo

getAliveCheckWorkerSet

public Set<String> getAliveCheckWorkerSet()

Getter method for property aliveCheckWorkerSet.

返回:

property value of aliveCheckWorkerSet

isInited

public boolean isInited()

getSerialNum

public long getSerialNum()

aquireSerialNum

public long aquireSerialNum()

checkProcessor

protected void checkProcessor()
                       throws Exception

抛出:

Exception