com.alibaba.schedulerx.worker.master

类 GridTaskMaster

java.lang.Object

com.alibaba.schedulerx.worker.master.TaskMaster

com.alibaba.schedulerx.worker.master.MapTaskMaster

com.alibaba.schedulerx.worker.master.GridTaskMaster

直接已知子类:

BatchTaskMaster, ShardingTaskMaster

public class GridTaskMaster
extends MapTaskMaster

GridTaskMaster, using MemoryPersistence

作者:

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

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
protected void	doMetricsCheck() Master各类指标信息检查
boolean	map(List<com.google.protobuf.ByteString> taskList, String taskName)
ProcessResult	postFinish(long jobInstanceId)

从类继承的方法 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, convert2StartContainerRequestBuilder, convert2StartContainerRequestBuilder, existInvalidWorker, getActorContext, getAliveCheckWorkerSet, getInstanceStatus, getJobInstanceInfo, getLocalContainerRouterPath, getLocalJobInstanceRouterPath, getLocalTaskRouterPath, getLocalWorkerIdAddr, getSerialNum, isInited, isJobInstanceFinished, isKilled, restJobInstanceWorkerList, retryTasks, setInstanceStatus, updateNewInstanceStatus, updateNewInstanceStatus

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

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

构造器详细资料

GridTaskMaster

public GridTaskMaster(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

doMetricsCheck

protected void doMetricsCheck()
                       throws IOException

Master各类指标信息检查

抛出:

IOException

postFinish

public ProcessResult postFinish(long jobInstanceId)

覆盖:

postFinish 在类中 MapTaskMaster