com.alibaba.schedulerx.worker.master

类 ShardingTaskMaster

java.lang.Object

com.alibaba.schedulerx.worker.master.TaskMaster

com.alibaba.schedulerx.worker.master.MapTaskMaster

com.alibaba.schedulerx.worker.master.GridTaskMaster

com.alibaba.schedulerx.worker.master.ShardingTaskMaster

public class ShardingTaskMaster
extends GridTaskMaster

作者:

xiaomeng.hxm

字段概要

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

futureExecutor, pageSize, queueSize, taskBlockingQueue, taskCounter, taskDispatchReqHandler, taskPersistence, taskProgressMap, taskStatusReqBatchHandler, taskStatusReqQueue, workerProgressMap, xAttrs

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

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

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
protected void	batchHandlePulledProgress(List<com.alibaba.schedulerx.protocol.Worker.MasterStartContainerRequest> masterStartContainerRequests, Map<String,List<com.alibaba.schedulerx.protocol.Worker.MasterStartContainerRequest>> worker2ReqsWithNormal, Map<String,List<com.alibaba.schedulerx.protocol.Worker.MasterStartContainerRequest>> worker2ReqsWithFailover, String remoteWorker)
void	batchUpdateTaskStatues(List<com.alibaba.schedulerx.protocol.Worker.ContainerReportTaskStatusRequest> requests)
protected void	checkProcessor()
void	clear()
String	getJobInstanceProgress()
ProcessResult	postFinish(long jobInstanceId)
void	submitInstance(com.alibaba.schedulerx.common.domain.JobInstanceInfo info)

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

map

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

batchDispatchTasks, batchDispatchTasks, batchPullTasks, clearTasks, createRootTask, destroyContainerPool, getRootTaskResult, getTaskProgressMap, init, killInstance, killTask, selectWorker, setRootTaskResult, startBatchHandler, stop, syncPullTasks, updateTaskStatus

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

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

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

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

构造器详细资料

ShardingTaskMaster

public ShardingTaskMaster(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 在类中 MapTaskMaster

batchUpdateTaskStatues

public void batchUpdateTaskStatues(List<com.alibaba.schedulerx.protocol.Worker.ContainerReportTaskStatusRequest> requests)

覆盖:

batchUpdateTaskStatues 在类中 MapTaskMaster

batchHandlePulledProgress

protected void batchHandlePulledProgress(List<com.alibaba.schedulerx.protocol.Worker.MasterStartContainerRequest> masterStartContainerRequests,
                                         Map<String,List<com.alibaba.schedulerx.protocol.Worker.MasterStartContainerRequest>> worker2ReqsWithNormal,
                                         Map<String,List<com.alibaba.schedulerx.protocol.Worker.MasterStartContainerRequest>> worker2ReqsWithFailover,
                                         String remoteWorker)

覆盖:

batchHandlePulledProgress 在类中 MapTaskMaster

getJobInstanceProgress

public String getJobInstanceProgress()

覆盖:

getJobInstanceProgress 在类中 MapTaskMaster

checkProcessor

protected void checkProcessor()
                       throws Exception

覆盖:

checkProcessor 在类中 MapTaskMaster

抛出:

Exception

postFinish

public ProcessResult postFinish(long jobInstanceId)

覆盖:

postFinish 在类中 GridTaskMaster

clear

public void clear()

覆盖:

clear 在类中 MapTaskMaster