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

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
protected void	doMetricsCheck() Master各类指标信息检查

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

map, 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, 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

构造器详细资料

BatchTaskMaster

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

抛出:

Exception

方法详细资料

doMetricsCheck

protected void doMetricsCheck()
                       throws IOException

Master各类指标信息检查

覆盖:

doMetricsCheck 在类中 GridTaskMaster

抛出:

IOException