com.alibaba.schedulerx.worker.master

类 BatchTaskMaster

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.BatchTaskMaster

public class BatchTaskMaster
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

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
boolean	map(List<com.google.protobuf.ByteString> taskList, String taskName)

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

postFinish

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

batchDispatchTasks, batchDispatchTasks, batchHandlePulledProgress, batchPullTasks, batchUpdateTaskStatues, checkProcessor, clear, clearTasks, createRootTask, destroyContainerPool, getJobInstanceProgress, getRootTaskResult, getTaskProgressMap, init, killInstance, killTask, selectWorker, setRootTaskResult, startBatchHandler, stop, submitInstance, 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

构造器详细资料

BatchTaskMaster

public BatchTaskMaster(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 在类中 GridTaskMaster

抛出:

Exception