所有程序包的分层结构

程序包分层结构:

• com.alibaba.schedulerx.worker,
• com.alibaba.schedulerx.worker.actor,
• com.alibaba.schedulerx.worker.actor.routing,
• com.alibaba.schedulerx.worker.batch,
• com.alibaba.schedulerx.worker.container,
• com.alibaba.schedulerx.worker.discovery,
• com.alibaba.schedulerx.worker.domain,
• com.alibaba.schedulerx.worker.exception,
• com.alibaba.schedulerx.worker.ha,
• com.alibaba.schedulerx.worker.log,
• com.alibaba.schedulerx.worker.log.appender,
• com.alibaba.schedulerx.worker.log.factory,
• com.alibaba.schedulerx.worker.log.logger,
• com.alibaba.schedulerx.worker.logcollector,
• com.alibaba.schedulerx.worker.master,
• com.alibaba.schedulerx.worker.master.handler,
• com.alibaba.schedulerx.worker.master.persistence,
• com.alibaba.schedulerx.worker.metrics,
• com.alibaba.schedulerx.worker.processor,
• com.alibaba.schedulerx.worker.processor.demo,
• com.alibaba.schedulerx.worker.pull,
• com.alibaba.schedulerx.worker.security,
• com.alibaba.schedulerx.worker.timer,
• com.alibaba.schedulerx.worker.util

类分层结构

• java.lang.Object
  • org.apache.logging.log4j.core.AbstractLifeCycle (implements org.apache.logging.log4j.core.LifeCycle2)
    • org.apache.logging.log4j.core.filter.AbstractFilterable (implements org.apache.logging.log4j.core.filter.Filterable)
      • org.apache.logging.log4j.core.appender.AbstractAppender (implements org.apache.logging.log4j.core.Appender, org.apache.logging.log4j.core.impl.LocationAware)
        • com.alibaba.schedulerx.worker.log.appender.SchedulerxLog4j2Appender
  • com.alibaba.schedulerx.worker.container.ActorContainer (implements com.alibaba.schedulerx.worker.container.Container)
  • com.alibaba.schedulerx.worker.util.ActorPathUtil
  • com.alibaba.schedulerx.worker.security.AliyunAuthenticator (implements com.alibaba.schedulerx.worker.security.Authenticator)
  • org.apache.log4j.AppenderSkeleton (implements org.apache.log4j.Appender, org.apache.log4j.spi.OptionHandler)
    • com.alibaba.schedulerx.worker.log.appender.SchedulerxLog4jAppender
  • com.alibaba.schedulerx.worker.discovery.ArmoryGroupDiscovery (implements com.alibaba.schedulerx.worker.discovery.GroupDiscovery)
  • com.alibaba.schedulerx.worker.discovery.ArmoryResult
  • com.alibaba.schedulerx.worker.discovery.ArmoryResult.ArmoryData
  • com.alibaba.schedulerx.worker.batch.BaseReqHandler<T>
    • com.alibaba.schedulerx.worker.batch.ContainerStatusReqHandler<T>
    • com.alibaba.schedulerx.worker.batch.TaskDispatchReqHandler<T>
      • com.alibaba.schedulerx.worker.pull.TaskPullReqHandler<T>
      • com.alibaba.schedulerx.worker.batch.TaskPushReqHandler<T>
    • com.alibaba.schedulerx.worker.batch.TMStatusReqHandler<T>
  • com.alibaba.schedulerx.worker.pull.BlockingContainerQueue
  • com.alibaba.schedulerx.worker.metrics.CgroupMetrics
  • com.alibaba.schedulerx.worker.logcollector.ClientLoggerMessage
  • com.alibaba.schedulerx.worker.util.ConsoleUtil
  • com.alibaba.schedulerx.worker.container.ContainerFactory
  • com.alibaba.schedulerx.worker.container.ContainerPool
    • com.alibaba.schedulerx.worker.container.ThreadContainerPool
  • com.alibaba.schedulerx.worker.util.ContanerUtil
  • ch.qos.logback.core.spi.ContextAwareBase (implements ch.qos.logback.core.spi.ContextAware)
    • ch.qos.logback.core.UnsynchronizedAppenderBase<E> (implements ch.qos.logback.core.Appender<E>)
      • com.alibaba.schedulerx.worker.log.appender.SchedulerxLogbackAppender<E>
  • com.alibaba.schedulerx.worker.security.DefaultAuthenticator (implements com.alibaba.schedulerx.worker.security.Authenticator)
  • com.alibaba.schedulerx.worker.discovery.DefaultGroupDiscovery (implements com.alibaba.schedulerx.worker.discovery.GroupDiscovery)
  • com.alibaba.schedulerx.worker.discovery.DefaultServerDiscovery (implements com.alibaba.schedulerx.worker.discovery.ServerDiscovery)
  • com.alibaba.schedulerx.worker.util.DiamondUtil
  • com.alibaba.schedulerx.worker.container.DockerContainer (implements com.alibaba.schedulerx.worker.container.Container)
  • com.alibaba.schedulerx.worker.util.FileDownloader
  • com.alibaba.schedulerx.worker.master.persistence.H2ConnectionPool
  • com.alibaba.schedulerx.worker.master.persistence.H2Persistence (implements com.alibaba.schedulerx.worker.master.persistence.TaskPersistence)
    • com.alibaba.schedulerx.worker.master.persistence.H2FilePersistence
    • com.alibaba.schedulerx.worker.master.persistence.H2MemoryPersistence
  • com.alibaba.schedulerx.worker.ha.HealthTimeHolder
  • com.alibaba.schedulerx.worker.actor.routing.InstanceRoutingLogic (implements akka.routing.RoutingLogic)
  • com.alibaba.schedulerx.worker.processor.JavaProcessor (implements com.alibaba.schedulerx.worker.processor.JobProcessorEx)
    • com.alibaba.schedulerx.worker.processor.DataWorksProcessor
    • com.alibaba.schedulerx.worker.processor.MapJobProcessor
      • com.alibaba.schedulerx.worker.processor.MapReduceJobProcessor
        • com.alibaba.schedulerx.worker.processor.demo.TestMapReduceJobProcessor
      • com.alibaba.schedulerx.worker.processor.demo.TestGridJobProcessor
      • com.alibaba.schedulerx.worker.processor.demo.TestParallelJobProcessor
    • com.alibaba.schedulerx.worker.processor.StreamJobProcessor
    • com.alibaba.schedulerx.worker.processor.demo.TestBroadcastJobProcessor
    • com.alibaba.schedulerx.worker.processor.demo.TestSimpleJobExceptionProcessor
    • com.alibaba.schedulerx.worker.processor.demo.TestSimpleJobFailProcessor
    • com.alibaba.schedulerx.worker.processor.demo.TestSimpleJobProcessor
    • com.alibaba.schedulerx.worker.processor.demo.TestSimpleJobProcessorWithKill
  • com.alibaba.schedulerx.worker.domain.JavaProcessorProfile
    • com.alibaba.schedulerx.worker.domain.DataworksProcessorProfile
  • com.alibaba.schedulerx.worker.util.JavaProcessorProfileUtil
  • com.alibaba.schedulerx.worker.domain.JobContext
  • com.alibaba.schedulerx.worker.domain.JobContext.JobContextBuilder
  • com.alibaba.schedulerx.worker.processor.JobProcessorRepository
  • com.alibaba.schedulerx.worker.log.logger.Log4j2Logger (implements com.alibaba.schedulerx.worker.log.Logger)
  • com.alibaba.schedulerx.worker.log.factory.Log4j2LoggerFactory (implements com.alibaba.schedulerx.worker.log.factory.SchedulerxLoggerFactory)
  • com.alibaba.schedulerx.worker.log.logger.Log4jLogger (implements com.alibaba.schedulerx.worker.log.Logger)
  • com.alibaba.schedulerx.worker.log.factory.Log4jLoggerFactory (implements com.alibaba.schedulerx.worker.log.factory.SchedulerxLoggerFactory)
  • com.alibaba.schedulerx.worker.log.logger.LogbackLogger (implements com.alibaba.schedulerx.worker.log.Logger)
  • com.alibaba.schedulerx.worker.log.factory.LogbackLoggerFactory (implements com.alibaba.schedulerx.worker.log.factory.SchedulerxLoggerFactory)
  • com.alibaba.schedulerx.worker.logcollector.LogCleaner
    • com.alibaba.schedulerx.worker.logcollector.LocalLogCleaner
  • com.alibaba.schedulerx.worker.logcollector.LogCollector
    • com.alibaba.schedulerx.worker.logcollector.DefaultLogCollector
    • com.alibaba.schedulerx.worker.logcollector.SlsLogCollector
  • com.alibaba.schedulerx.worker.logcollector.LogCollectorFactory
  • com.alibaba.schedulerx.worker.log.LogFactory
  • com.alibaba.schedulerx.worker.domain.MapTaskListInfo
  • com.alibaba.schedulerx.worker.log.logger.NopLogger (implements com.alibaba.schedulerx.worker.log.Logger)
  • com.alibaba.schedulerx.worker.log.factory.NopLoggerFactory (implements com.alibaba.schedulerx.worker.log.factory.SchedulerxLoggerFactory)
  • com.alibaba.schedulerx.worker.master.persistence.PersistenceUtil
  • com.alibaba.schedulerx.worker.container.ProcessContainer (implements com.alibaba.schedulerx.worker.container.Container)
  • com.alibaba.schedulerx.worker.processor.ProcessorFactory
  • com.alibaba.schedulerx.worker.processor.ProcessResult
  • com.alibaba.schedulerx.worker.batch.ReqQueue<T>
  • com.alibaba.schedulerx.worker.log.appender.SchedulerxLog4j2AppenderCallback (implements com.aliyun.openservices.aliyun.log.producer.Callback)
  • com.alibaba.schedulerx.worker.log.appender.SchedulerxLog4jAppenderCallback (implements com.aliyun.openservices.aliyun.log.producer.Callback)
  • com.alibaba.schedulerx.worker.log.appender.SchedulerxLogbackAppenderCallBack<E> (implements com.aliyun.openservices.aliyun.log.producer.Callback)
  • com.alibaba.schedulerx.worker.SchedulerxWorker (implements org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationListener<E>, org.springframework.beans.factory.InitializingBean)
  • com.alibaba.schedulerx.worker.domain.SecondTaskProgress
  • com.alibaba.schedulerx.worker.discovery.ServerDiscoveryFactory
  • com.alibaba.schedulerx.worker.master.persistence.ServerTaskPersistence (implements com.alibaba.schedulerx.worker.master.persistence.TaskPersistence)
  • com.alibaba.schedulerx.worker.domain.ShardingTask
  • com.alibaba.schedulerx.worker.processor.ShellProcessor (implements com.alibaba.schedulerx.worker.processor.JobProcessorEx)
    • com.alibaba.schedulerx.worker.processor.GoProcessor
    • com.alibaba.schedulerx.worker.processor.PythonProcessor
  • com.alibaba.schedulerx.worker.util.ShellUtil
  • com.alibaba.schedulerx.worker.util.SpringContext
  • com.alibaba.schedulerx.worker.util.SystemManagementUtil
  • com.alibaba.schedulerx.worker.master.persistence.TaskDao
  • com.alibaba.schedulerx.worker.domain.TaskInfo
  • com.alibaba.schedulerx.worker.domain.TaskInfo.TaskInfoBuilder
  • com.alibaba.schedulerx.worker.master.TaskMaster
    • com.alibaba.schedulerx.worker.master.BroadcastTaskMaster
    • com.alibaba.schedulerx.worker.master.MapTaskMaster
      • com.alibaba.schedulerx.worker.master.GridTaskMaster
        • com.alibaba.schedulerx.worker.master.BatchTaskMaster
        • com.alibaba.schedulerx.worker.master.ShardingTaskMaster
      • com.alibaba.schedulerx.worker.master.ParallelTaskMater
    • com.alibaba.schedulerx.worker.master.StandaloneTaskMaster
  • com.alibaba.schedulerx.worker.master.TaskMasterFactory
  • com.alibaba.schedulerx.worker.master.persistence.TaskSnapshot
  • com.alibaba.schedulerx.worker.domain.TaskStatistics
  • com.alibaba.schedulerx.worker.TestLocalClient
  • com.alibaba.schedulerx.worker.processor.demo.TestTaskObject (implements java.io.Serializable)
  • java.lang.Thread (implements java.lang.Runnable)
    • com.alibaba.schedulerx.worker.pull.PullThread
    • com.alibaba.schedulerx.worker.processor.ShellStreamProcessor
  • com.alibaba.schedulerx.worker.container.ThreadContainer (implements com.alibaba.schedulerx.worker.container.Container, java.lang.Runnable)
    • com.alibaba.schedulerx.worker.pull.ConsumerThread
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • com.alibaba.schedulerx.worker.exception.AuthenticateException
      • com.alibaba.schedulerx.worker.exception.DomainInvalidException
      • com.alibaba.schedulerx.worker.exception.DomainNotFoundException
      • com.alibaba.schedulerx.worker.exception.NamespaceNotFoundException
      • com.alibaba.schedulerx.worker.exception.ServerNotFoundException
      • com.alibaba.schedulerx.worker.exception.TimeOffsetException
  • com.alibaba.schedulerx.worker.util.TimeResolver
  • java.util.TimerTask (implements java.lang.Runnable)
    • com.alibaba.schedulerx.worker.timer.AbstractTimerTask
      • com.alibaba.schedulerx.worker.timer.DomainNameUpdateTimer
      • com.alibaba.schedulerx.worker.timer.JobInstanceCheckTimer
      • com.alibaba.schedulerx.worker.timer.JobInstanceCleanTimer
      • com.alibaba.schedulerx.worker.timer.MetricsCollectorTimer
      • com.alibaba.schedulerx.worker.timer.TaskMasterUpdateWorkersTimer
      • com.alibaba.schedulerx.worker.timer.ZombieContainerCheckTimer
  • com.alibaba.schedulerx.worker.util.UnirestUtil
  • akka.actor.UntypedActor (implements akka.actor.Actor)
    • com.alibaba.schedulerx.worker.ha.AtLeastOnceDeliveryRoutingActor
    • com.alibaba.schedulerx.worker.actor.ContainerActor
    • com.alibaba.schedulerx.worker.actor.ContainerRoutingActor
    • com.alibaba.schedulerx.worker.actor.JobInstanceActor
    • com.alibaba.schedulerx.worker.actor.LogActor
    • com.alibaba.schedulerx.worker.actor.TaskActor
    • com.alibaba.schedulerx.worker.actor.TaskRouter
    • akka.persistence.UntypedPersistentActor (implements akka.persistence.Eventsourced)
      • akka.persistence.UntypedPersistentActorWithAtLeastOnceDelivery (implements akka.persistence.AtLeastOnceDeliveryLike)
        • com.alibaba.schedulerx.worker.ha.AtLeastOnceDeliveryActor
    • com.alibaba.schedulerx.worker.actor.WorkerHeartbeatActor
  • com.alibaba.schedulerx.worker.master.handler.UpdateInstanceStatusHandler
    • com.alibaba.schedulerx.worker.master.handler.CommonUpdateInstanceStatusHandler
    • com.alibaba.schedulerx.worker.master.handler.SecondJobUpdateInstanceStatusHandler
  • com.alibaba.schedulerx.worker.master.handler.UpdateInstanceStatusHandlerFactory
  • com.alibaba.schedulerx.worker.util.WorkerIdGenerator

接口分层结构

• com.alibaba.schedulerx.worker.security.Authenticator
• com.alibaba.schedulerx.worker.processor.BaseProcessor
  • com.alibaba.schedulerx.worker.processor.JobProcessor
    • com.alibaba.schedulerx.worker.processor.JobProcessorEx
  • com.alibaba.schedulerx.worker.processor.JobProcessorEx
• com.alibaba.schedulerx.worker.processor.BizSubTask
• com.alibaba.schedulerx.worker.container.Container
• com.alibaba.schedulerx.worker.discovery.GroupDiscovery
• com.alibaba.schedulerx.worker.log.Logger
• com.alibaba.schedulerx.worker.log.factory.SchedulerxLoggerFactory
• com.alibaba.schedulerx.worker.discovery.ServerDiscovery
• com.alibaba.schedulerx.worker.master.persistence.TaskPersistence
• com.alibaba.schedulerx.worker.domain.WorkerConstants

枚举分层结构

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • com.alibaba.schedulerx.worker.pull.PullManager
    • com.alibaba.schedulerx.worker.discovery.GroupManager
    • com.alibaba.schedulerx.worker.master.TaskMasterPool
    • com.alibaba.schedulerx.worker.batch.ContainerStatusReqHandlerPool
    • com.alibaba.schedulerx.worker.log.appender.LogConfig
    • com.alibaba.schedulerx.worker.actor.FutureExecutorPool