com.alibaba.schedulerx.worker.master

类 ParallelTaskMater

java.lang.Object

com.alibaba.schedulerx.worker.master.TaskMaster

com.alibaba.schedulerx.worker.master.MapTaskMaster

com.alibaba.schedulerx.worker.master.ParallelTaskMater

public class ParallelTaskMater
extends MapTaskMaster

ParallelTaskMater, using ServerTaskPersistence

作者:

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

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
boolean	map(List<com.google.protobuf.ByteString> taskList, String taskName)
void	retryTasks(List<com.alibaba.schedulerx.protocol.Server.RetryTaskEntity> taskEntities)

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

batchDispatchTasks, batchDispatchTasks, batchHandlePulledProgress, batchPullTasks, batchUpdateTaskStatues, checkProcessor, clear, clearTasks, createRootTask, destroyContainerPool, getJobInstanceProgress, getRootTaskResult, getTaskProgressMap, init, killInstance, killTask, postFinish, selectWorker, setRootTaskResult, startBatchHandler, stop, submitInstance, syncPullTasks, updateTaskStatus

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

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

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

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

构造器详细资料

ParallelTaskMater

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

抛出:

Exception

方法详细资料

map

public boolean map(List<com.google.protobuf.ByteString> taskList,
                   String taskName)
            throws Exception

覆盖:

map 在类中 MapTaskMaster

抛出:

Exception

retryTasks

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

覆盖:

retryTasks 在类中 TaskMaster