所有程序包的分层结构

程序包分层结构:

• com.dangdang.ddframe.job.api,
• com.dangdang.ddframe.job.api.listener,
• com.dangdang.ddframe.job.exception,
• com.dangdang.ddframe.job.internal.config,
• com.dangdang.ddframe.job.internal.election,
• com.dangdang.ddframe.job.internal.env,
• com.dangdang.ddframe.job.internal.execution,
• com.dangdang.ddframe.job.internal.failover,
• com.dangdang.ddframe.job.internal.guarantee,
• com.dangdang.ddframe.job.internal.job,
• com.dangdang.ddframe.job.internal.job.dataflow,
• com.dangdang.ddframe.job.internal.listener,
• com.dangdang.ddframe.job.internal.monitor,
• com.dangdang.ddframe.job.internal.offset,
• com.dangdang.ddframe.job.internal.schedule,
• com.dangdang.ddframe.job.internal.server,
• com.dangdang.ddframe.job.internal.sharding,
• com.dangdang.ddframe.job.internal.sharding.strategy,
• com.dangdang.ddframe.job.internal.statistics,
• com.dangdang.ddframe.job.internal.storage,
• com.dangdang.ddframe.job.internal.util,
• com.dangdang.ddframe.job.plugin.job.type.dataflow,
• com.dangdang.ddframe.job.plugin.job.type.simple,
• com.dangdang.ddframe.job.plugin.sharding.strategy,
• com.dangdang.ddframe.job.schedule,
• com.dangdang.ddframe.reg.base,
• com.dangdang.ddframe.reg.exception,
• com.dangdang.ddframe.reg.zookeeper

类分层结构

• java.lang.Object
  • com.dangdang.ddframe.job.api.listener.AbstractDistributeOnceElasticJobListener (implements com.dangdang.ddframe.job.api.listener.ElasticJobListener)
  • com.dangdang.ddframe.job.internal.job.AbstractElasticJob (implements com.dangdang.ddframe.job.api.ElasticJob)
    • com.dangdang.ddframe.job.internal.job.dataflow.AbstractDataFlowElasticJob<T,C> (implements com.dangdang.ddframe.job.api.DataFlowElasticJob<T,C>)
      • com.dangdang.ddframe.job.internal.job.dataflow.AbstractBatchDataFlowElasticJob<T,C> (implements com.dangdang.ddframe.job.internal.job.dataflow.BatchProcessable<T,C>)
        • com.dangdang.ddframe.job.plugin.job.type.dataflow.AbstractBatchSequenceDataFlowElasticJob<T>
        • com.dangdang.ddframe.job.plugin.job.type.dataflow.AbstractBatchThroughputDataFlowElasticJob<T>
      • com.dangdang.ddframe.job.internal.job.dataflow.AbstractIndividualDataFlowElasticJob<T,C> (implements com.dangdang.ddframe.job.internal.job.dataflow.IndividualProcessable<T,C>)
        • com.dangdang.ddframe.job.plugin.job.type.dataflow.AbstractIndividualSequenceDataFlowElasticJob<T>
        • com.dangdang.ddframe.job.plugin.job.type.dataflow.AbstractIndividualThroughputDataFlowElasticJob<T>
        • com.dangdang.ddframe.job.api.AbstractPerpetualElasticJob<T>
        • com.dangdang.ddframe.job.api.AbstractSequencePerpetualElasticJob<T>
    • com.dangdang.ddframe.job.plugin.job.type.simple.AbstractSimpleElasticJob
      • com.dangdang.ddframe.job.api.AbstractOneOffElasticJob
  • com.dangdang.ddframe.job.internal.job.AbstractJobExecutionShardingContext
    • com.dangdang.ddframe.job.api.JobExecutionMultipleShardingContext
    • com.dangdang.ddframe.job.api.JobExecutionSingleShardingContext
  • com.dangdang.ddframe.job.internal.listener.AbstractJobListener (implements org.apache.curator.framework.recipes.cache.TreeCacheListener)
  • com.dangdang.ddframe.job.internal.listener.AbstractListenerManager
    • com.dangdang.ddframe.job.internal.config.ConfigurationListenerManager
    • com.dangdang.ddframe.job.internal.election.ElectionListenerManager
    • com.dangdang.ddframe.job.internal.execution.ExecutionListenerManager
    • com.dangdang.ddframe.job.internal.failover.FailoverListenerManager
    • com.dangdang.ddframe.job.internal.guarantee.GuaranteeListenerManager
    • com.dangdang.ddframe.job.internal.server.JobOperationListenerManager
    • com.dangdang.ddframe.job.internal.sharding.ShardingListenerManager
  • com.dangdang.ddframe.reg.base.AbstractRegistryCenterConfiguration
    • com.dangdang.ddframe.reg.zookeeper.ZookeeperConfiguration
  • com.dangdang.ddframe.job.plugin.sharding.strategy.AverageAllocationJobShardingStrategy (implements com.dangdang.ddframe.job.internal.sharding.strategy.JobShardingStrategy)
  • com.dangdang.ddframe.job.internal.util.BlockUtils
  • com.dangdang.ddframe.job.internal.config.ConfigurationNode
  • com.dangdang.ddframe.job.internal.config.ConfigurationService
  • com.dangdang.ddframe.job.internal.election.ElectionNode
  • com.dangdang.ddframe.job.internal.execution.ExecutionContextService
  • com.dangdang.ddframe.job.internal.execution.ExecutionNode
  • com.dangdang.ddframe.job.internal.execution.ExecutionService
  • com.dangdang.ddframe.job.internal.failover.FailoverNode
  • com.dangdang.ddframe.job.internal.failover.FailoverService
  • com.dangdang.ddframe.job.internal.guarantee.GuaranteeNode
  • com.dangdang.ddframe.job.internal.guarantee.GuaranteeService
  • com.dangdang.ddframe.job.internal.util.ItemUtils
  • com.dangdang.ddframe.job.api.JobConfiguration
  • com.dangdang.ddframe.job.internal.schedule.JobFacade
  • com.dangdang.ddframe.job.internal.storage.JobNodePath
  • com.dangdang.ddframe.job.internal.storage.JobNodeStorage
  • com.dangdang.ddframe.job.internal.schedule.JobRegistry
  • com.dangdang.ddframe.job.api.JobScheduler
    • com.dangdang.ddframe.job.schedule.JobController
  • com.dangdang.ddframe.job.internal.sharding.strategy.JobShardingStrategyFactory
  • com.dangdang.ddframe.job.internal.sharding.strategy.JobShardingStrategyOption
  • com.dangdang.ddframe.job.internal.election.LeaderElectionService
  • com.dangdang.ddframe.job.internal.listener.ListenerManager
  • com.dangdang.ddframe.job.internal.env.LocalHostService
  • com.dangdang.ddframe.job.internal.monitor.MonitorService
  • com.dangdang.ddframe.reg.zookeeper.NestedZookeeperServers
  • com.dangdang.ddframe.job.plugin.sharding.strategy.OdevitySortByNameJobShardingStrategy (implements com.dangdang.ddframe.job.internal.sharding.strategy.JobShardingStrategy)
  • com.dangdang.ddframe.job.internal.offset.OffsetNode
  • com.dangdang.ddframe.job.internal.offset.OffsetService
  • com.dangdang.ddframe.job.internal.statistics.ProcessCountJob (implements java.lang.Runnable)
  • com.dangdang.ddframe.job.internal.statistics.ProcessCountStatistics
  • com.dangdang.ddframe.reg.exception.RegExceptionHandler
  • com.dangdang.ddframe.job.plugin.sharding.strategy.RotateServerByNameJobShardingStrategy (implements com.dangdang.ddframe.job.internal.sharding.strategy.JobShardingStrategy)
  • com.dangdang.ddframe.job.internal.schedule.SchedulerFacade
  • com.dangdang.ddframe.job.internal.util.SensitiveInfoUtils
  • com.dangdang.ddframe.job.internal.server.ServerNode
  • com.dangdang.ddframe.job.internal.server.ServerService
  • com.dangdang.ddframe.job.internal.sharding.ShardingService
  • com.dangdang.ddframe.job.internal.statistics.StatisticsService
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • com.dangdang.ddframe.job.exception.JobException
          • com.dangdang.ddframe.job.exception.JobConflictException
          • com.dangdang.ddframe.job.exception.JobShardingStrategyClassConfigurationException
          • com.dangdang.ddframe.job.exception.JobTimeoutException
          • com.dangdang.ddframe.job.exception.ShardingItemParametersException
          • com.dangdang.ddframe.job.exception.TimeDiffIntolerableException
        • com.dangdang.ddframe.reg.exception.RegException
          • com.dangdang.ddframe.reg.exception.LocalPropertiesFileNotFoundException
  • com.dangdang.ddframe.job.internal.env.TimeService
  • org.quartz.listeners.TriggerListenerSupport (implements org.quartz.TriggerListener)
    • com.dangdang.ddframe.job.internal.schedule.JobTriggerListener
  • com.dangdang.ddframe.reg.zookeeper.ZookeeperRegistryCenter (implements com.dangdang.ddframe.reg.base.CoordinatorRegistryCenter)

接口分层结构

• com.dangdang.ddframe.job.internal.job.dataflow.BatchProcessable<T,C>
• com.dangdang.ddframe.job.api.listener.ElasticJobListener
• com.dangdang.ddframe.job.internal.job.dataflow.IndividualProcessable<T,C>
• org.quartz.Job
  • com.dangdang.ddframe.job.api.DataFlowElasticJob<T,C>
  • com.dangdang.ddframe.job.api.ElasticJob
    • com.dangdang.ddframe.job.api.DataFlowElasticJob<T,C>
• com.dangdang.ddframe.job.internal.sharding.strategy.JobShardingStrategy
• com.dangdang.ddframe.job.internal.storage.LeaderExecutionCallback
• com.dangdang.ddframe.reg.base.RegistryCenter
  • com.dangdang.ddframe.reg.base.CoordinatorRegistryCenter
• com.dangdang.ddframe.job.internal.storage.TransactionExecutionCallback

枚举分层结构

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • com.dangdang.ddframe.job.internal.job.dataflow.DataFlowType
    • com.dangdang.ddframe.job.internal.server.ServerStatus