索引 (elastic-job-core 1.0.6 API)

A B C D E F G H I J L M N O P R S T U V W Z

A

AbstractBatchDataFlowElasticJob<T,C extends AbstractJobExecutionShardingContext> - com.dangdang.ddframe.job.internal.job.dataflow中的类: 用于批量处理数据流程的作业抽象类.
AbstractBatchDataFlowElasticJob() - 类的构造器com.dangdang.ddframe.job.internal.job.dataflow.AbstractBatchDataFlowElasticJob
AbstractBatchSequenceDataFlowElasticJob<T> - com.dangdang.ddframe.job.plugin.job.type.dataflow中的类: 保证同一分片顺序性的批量处理数据流程的作业.
AbstractBatchSequenceDataFlowElasticJob() - 类的构造器com.dangdang.ddframe.job.plugin.job.type.dataflow.AbstractBatchSequenceDataFlowElasticJob
AbstractBatchThroughputDataFlowElasticJob<T> - com.dangdang.ddframe.job.plugin.job.type.dataflow中的类: 高吞吐量批量处理数据流程的作业.
AbstractBatchThroughputDataFlowElasticJob() - 类的构造器com.dangdang.ddframe.job.plugin.job.type.dataflow.AbstractBatchThroughputDataFlowElasticJob
AbstractDataFlowElasticJob<T,C extends AbstractJobExecutionShardingContext> - com.dangdang.ddframe.job.internal.job.dataflow中的类: 用于处理数据流程的作业抽象类.
AbstractDataFlowElasticJob() - 类的构造器com.dangdang.ddframe.job.internal.job.dataflow.AbstractDataFlowElasticJob
AbstractDistributeOnceElasticJobListener - com.dangdang.ddframe.job.api.listener中的类: 在分布式作业中只执行一次的监听器.
AbstractDistributeOnceElasticJobListener(long, long) - 类的构造器com.dangdang.ddframe.job.api.listener.AbstractDistributeOnceElasticJobListener
AbstractElasticJob - com.dangdang.ddframe.job.internal.job中的类: 弹性化分布式作业的基类.
AbstractElasticJob() - 类的构造器com.dangdang.ddframe.job.internal.job.AbstractElasticJob
AbstractIndividualDataFlowElasticJob<T,C extends AbstractJobExecutionShardingContext> - com.dangdang.ddframe.job.internal.job.dataflow中的类: 用于逐条处理数据流程的作业抽象类.
AbstractIndividualDataFlowElasticJob() - 类的构造器com.dangdang.ddframe.job.internal.job.dataflow.AbstractIndividualDataFlowElasticJob
AbstractIndividualSequenceDataFlowElasticJob<T> - com.dangdang.ddframe.job.plugin.job.type.dataflow中的类: 保证同一分片顺序性的逐条处理数据流程的作业.
AbstractIndividualSequenceDataFlowElasticJob() - 类的构造器com.dangdang.ddframe.job.plugin.job.type.dataflow.AbstractIndividualSequenceDataFlowElasticJob
AbstractIndividualThroughputDataFlowElasticJob<T> - com.dangdang.ddframe.job.plugin.job.type.dataflow中的类: 高吞吐量逐条处理数据流程的作业.
AbstractIndividualThroughputDataFlowElasticJob() - 类的构造器com.dangdang.ddframe.job.plugin.job.type.dataflow.AbstractIndividualThroughputDataFlowElasticJob
AbstractJobExecutionShardingContext - com.dangdang.ddframe.job.internal.job中的类: 作业运行时分片上下文抽象类.
AbstractJobExecutionShardingContext() - 类的构造器com.dangdang.ddframe.job.internal.job.AbstractJobExecutionShardingContext
AbstractJobListener - com.dangdang.ddframe.job.internal.listener中的类: 作业注册中心的监听器.
AbstractJobListener() - 类的构造器com.dangdang.ddframe.job.internal.listener.AbstractJobListener
AbstractListenerManager - com.dangdang.ddframe.job.internal.listener中的类: 作业注册中心的监听器管理者的抽象类.
AbstractListenerManager(CoordinatorRegistryCenter, JobConfiguration) - 类的构造器com.dangdang.ddframe.job.internal.listener.AbstractListenerManager
AbstractOneOffElasticJob - com.dangdang.ddframe.job.api中的类: 已过时。
.
AbstractOneOffElasticJob() - 类的构造器com.dangdang.ddframe.job.api.AbstractOneOffElasticJob: 已过时。
AbstractPerpetualElasticJob<T> - com.dangdang.ddframe.job.api中的类: 已过时。
.
AbstractPerpetualElasticJob() - 类的构造器com.dangdang.ddframe.job.api.AbstractPerpetualElasticJob: 已过时。
AbstractRegistryCenterConfiguration - com.dangdang.ddframe.reg.base中的类: 注册中心配置抽象类.
AbstractRegistryCenterConfiguration() - 类的构造器com.dangdang.ddframe.reg.base.AbstractRegistryCenterConfiguration
AbstractSequencePerpetualElasticJob<T> - com.dangdang.ddframe.job.api中的类: 已过时。
.
AbstractSequencePerpetualElasticJob() - 类的构造器com.dangdang.ddframe.job.api.AbstractSequencePerpetualElasticJob: 已过时。
AbstractSimpleElasticJob - com.dangdang.ddframe.job.plugin.job.type.simple中的类: 简单的分布式作业.
AbstractSimpleElasticJob() - 类的构造器com.dangdang.ddframe.job.plugin.job.type.simple.AbstractSimpleElasticJob
addCacheData(String) - 接口中的方法com.dangdang.ddframe.reg.base.CoordinatorRegistryCenter: 添加本地缓存.
addCacheData(String) - 类中的方法com.dangdang.ddframe.reg.zookeeper.ZookeeperRegistryCenter
addConnectionStateListener(ConnectionStateListener) - 类中的方法com.dangdang.ddframe.job.internal.listener.AbstractListenerManager
addConnectionStateListener(ConnectionStateListener) - 类中的方法com.dangdang.ddframe.job.internal.storage.JobNodeStorage: 注册连接状态监听器.
addDataListener(TreeCacheListener) - 类中的方法com.dangdang.ddframe.job.internal.listener.AbstractListenerManager
addDataListener(TreeCacheListener) - 类中的方法com.dangdang.ddframe.job.internal.storage.JobNodeStorage: 注册数据监听器.
addJobInstance(String, ElasticJob) - 类中的方法com.dangdang.ddframe.job.internal.schedule.JobRegistry: 添加作业实例.
addJobScheduler(String, JobScheduler) - 类中的方法com.dangdang.ddframe.job.internal.schedule.JobRegistry: 添加作业控制器.
afterJobExecuted(JobExecutionMultipleShardingContext) - 类中的方法com.dangdang.ddframe.job.api.listener.AbstractDistributeOnceElasticJobListener
afterJobExecuted(JobExecutionMultipleShardingContext) - 接口中的方法com.dangdang.ddframe.job.api.listener.ElasticJobListener: 作业执行后的执行的方法.
afterJobExecuted(JobExecutionMultipleShardingContext) - 类中的方法com.dangdang.ddframe.job.internal.schedule.JobFacade: 作业执行后的执行的方法.
AverageAllocationJobShardingStrategy - com.dangdang.ddframe.job.plugin.sharding.strategy中的类: 基于平均分配算法的分片策略.
AverageAllocationJobShardingStrategy() - 类的构造器com.dangdang.ddframe.job.plugin.sharding.strategy.AverageAllocationJobShardingStrategy

B

BatchProcessable<T,C extends AbstractJobExecutionShardingContext> - com.dangdang.ddframe.job.internal.job.dataflow中的接口: 批量处理数据的接口.
beforeJobExecuted(JobExecutionMultipleShardingContext) - 类中的方法com.dangdang.ddframe.job.api.listener.AbstractDistributeOnceElasticJobListener
beforeJobExecuted(JobExecutionMultipleShardingContext) - 接口中的方法com.dangdang.ddframe.job.api.listener.ElasticJobListener: 作业执行前的执行的方法.
beforeJobExecuted(JobExecutionMultipleShardingContext) - 类中的方法com.dangdang.ddframe.job.internal.schedule.JobFacade: 作业执行前的执行的方法.
BlockUtils - com.dangdang.ddframe.job.internal.util中的类
BlockUtils() - 类的构造器com.dangdang.ddframe.job.internal.util.BlockUtils

C

checkMaxTimeDiffSecondsTolerable() - 类中的方法com.dangdang.ddframe.job.internal.config.ConfigurationService: 检查本机与注册中心的时间误差秒数是否在允许范围.
checkMaxTimeDiffSecondsTolerable() - 类中的方法com.dangdang.ddframe.job.internal.schedule.JobFacade: 检查本机与注册中心的时间误差秒数是否在允许范围.
childEvent(CuratorFramework, TreeCacheEvent) - 类中的方法com.dangdang.ddframe.job.internal.listener.AbstractJobListener
clearAllCompletedInfo() - 类中的方法com.dangdang.ddframe.job.internal.guarantee.GuaranteeService: 清理所有任务启动信息.
clearAllStartedInfo() - 类中的方法com.dangdang.ddframe.job.internal.guarantee.GuaranteeService: 清理所有任务启动信息.
clearJobStoppedStatus() - 类中的方法com.dangdang.ddframe.job.internal.server.ServerService: 清除停止作业的标记.
clearMisfire(List<Integer>) - 类中的方法com.dangdang.ddframe.job.internal.execution.ExecutionService: 清除任务被错过执行的标记.
clearMisfire(List<Integer>) - 类中的方法com.dangdang.ddframe.job.internal.schedule.JobFacade: 清除任务被错过执行的标记.
clearPreviousServerStatus() - 类中的方法com.dangdang.ddframe.job.internal.schedule.SchedulerFacade: 每次作业启动前清理上次运行状态.
clearPreviousServerStatus() - 类中的方法com.dangdang.ddframe.job.internal.server.ServerService: 每次作业启动前清理上次运行状态.
clearRunningInfo(List<Integer>) - 类中的方法com.dangdang.ddframe.job.internal.execution.ExecutionService: 清除分配分片序列号的运行状态.
close() - 类中的方法com.dangdang.ddframe.job.internal.monitor.MonitorService: 关闭作业监听服务.
close() - 接口中的方法com.dangdang.ddframe.reg.base.RegistryCenter: 关闭注册中心.
close() - 类中的方法com.dangdang.ddframe.reg.zookeeper.ZookeeperRegistryCenter
closeServer(int) - 类中的方法com.dangdang.ddframe.reg.zookeeper.NestedZookeeperServers: 关闭内嵌的Zookeeper服务.
com.dangdang.ddframe.job.api - 程序包 com.dangdang.ddframe.job.api
com.dangdang.ddframe.job.api.listener - 程序包 com.dangdang.ddframe.job.api.listener
com.dangdang.ddframe.job.exception - 程序包 com.dangdang.ddframe.job.exception
com.dangdang.ddframe.job.internal.config - 程序包 com.dangdang.ddframe.job.internal.config
com.dangdang.ddframe.job.internal.election - 程序包 com.dangdang.ddframe.job.internal.election
com.dangdang.ddframe.job.internal.env - 程序包 com.dangdang.ddframe.job.internal.env
com.dangdang.ddframe.job.internal.execution - 程序包 com.dangdang.ddframe.job.internal.execution
com.dangdang.ddframe.job.internal.failover - 程序包 com.dangdang.ddframe.job.internal.failover
com.dangdang.ddframe.job.internal.guarantee - 程序包 com.dangdang.ddframe.job.internal.guarantee
com.dangdang.ddframe.job.internal.job - 程序包 com.dangdang.ddframe.job.internal.job
com.dangdang.ddframe.job.internal.job.dataflow - 程序包 com.dangdang.ddframe.job.internal.job.dataflow
com.dangdang.ddframe.job.internal.listener - 程序包 com.dangdang.ddframe.job.internal.listener
com.dangdang.ddframe.job.internal.monitor - 程序包 com.dangdang.ddframe.job.internal.monitor
com.dangdang.ddframe.job.internal.offset - 程序包 com.dangdang.ddframe.job.internal.offset
com.dangdang.ddframe.job.internal.schedule - 程序包 com.dangdang.ddframe.job.internal.schedule
com.dangdang.ddframe.job.internal.server - 程序包 com.dangdang.ddframe.job.internal.server
com.dangdang.ddframe.job.internal.sharding - 程序包 com.dangdang.ddframe.job.internal.sharding
com.dangdang.ddframe.job.internal.sharding.strategy - 程序包 com.dangdang.ddframe.job.internal.sharding.strategy
com.dangdang.ddframe.job.internal.statistics - 程序包 com.dangdang.ddframe.job.internal.statistics
com.dangdang.ddframe.job.internal.storage - 程序包 com.dangdang.ddframe.job.internal.storage
com.dangdang.ddframe.job.internal.util - 程序包 com.dangdang.ddframe.job.internal.util
com.dangdang.ddframe.job.plugin.job.type.dataflow - 程序包 com.dangdang.ddframe.job.plugin.job.type.dataflow
com.dangdang.ddframe.job.plugin.job.type.simple - 程序包 com.dangdang.ddframe.job.plugin.job.type.simple
com.dangdang.ddframe.job.plugin.sharding.strategy - 程序包 com.dangdang.ddframe.job.plugin.sharding.strategy
com.dangdang.ddframe.job.schedule - 程序包 com.dangdang.ddframe.job.schedule
com.dangdang.ddframe.reg.base - 程序包 com.dangdang.ddframe.reg.base
com.dangdang.ddframe.reg.exception - 程序包 com.dangdang.ddframe.reg.exception
com.dangdang.ddframe.reg.zookeeper - 程序包 com.dangdang.ddframe.reg.zookeeper
ConfigurationListenerManager - com.dangdang.ddframe.job.internal.config中的类: 配置文件监听管理器.
ConfigurationListenerManager(CoordinatorRegistryCenter, JobConfiguration) - 类的构造器com.dangdang.ddframe.job.internal.config.ConfigurationListenerManager
ConfigurationNode - com.dangdang.ddframe.job.internal.config中的类: Elastic Job配置根节点名称的常量类.
ConfigurationNode(String) - 类的构造器com.dangdang.ddframe.job.internal.config.ConfigurationNode
ConfigurationService - com.dangdang.ddframe.job.internal.config中的类: 弹性化分布式作业配置服务.
ConfigurationService(CoordinatorRegistryCenter, JobConfiguration) - 类的构造器com.dangdang.ddframe.job.internal.config.ConfigurationService
CoordinatorRegistryCenter - com.dangdang.ddframe.reg.base中的接口: 用于协调分布式服务的注册中心.
createJobExecutionSingleShardingContext(int) - 类中的方法com.dangdang.ddframe.job.api.JobExecutionMultipleShardingContext: 根据分片项获取单分片作业运行时上下文.
createJobNodeIfNeeded(String) - 类中的方法com.dangdang.ddframe.job.internal.storage.JobNodeStorage: 如果存在则创建作业节点.

D

dataChanged(CuratorFramework, TreeCacheEvent, String) - 类中的方法com.dangdang.ddframe.job.internal.listener.AbstractJobListener
DataFlowElasticJob<T,C extends AbstractJobExecutionShardingContext> - com.dangdang.ddframe.job.api中的接口: 保用于处理数据流程的作业接口.
DataFlowType - com.dangdang.ddframe.job.internal.job.dataflow中的枚举: 数据流作业支持的处理类型.
doAfterJobExecutedAtLastCompleted(JobExecutionMultipleShardingContext) - 类中的方法com.dangdang.ddframe.job.api.listener.AbstractDistributeOnceElasticJobListener: 分布式环境中最后一个作业执行后的执行的方法.
doBeforeJobExecutedAtLastStarted(JobExecutionMultipleShardingContext) - 类中的方法com.dangdang.ddframe.job.api.listener.AbstractDistributeOnceElasticJobListener: 分布式环境中最后一个作业执行前的执行的方法.
DUMP_COMMAND - 类中的静态变量com.dangdang.ddframe.job.internal.monitor.MonitorService

E

ElasticJob - com.dangdang.ddframe.job.api中的接口: 弹性化分布式作业接口.
ElasticJobListener - com.dangdang.ddframe.job.api.listener中的接口: 弹性化分布式作业监听器接口.
ElectionListenerManager - com.dangdang.ddframe.job.internal.election中的类: 主节点选举监听管理器.
ElectionListenerManager(CoordinatorRegistryCenter, JobConfiguration) - 类的构造器com.dangdang.ddframe.job.internal.election.ElectionListenerManager
ElectionNode - com.dangdang.ddframe.job.internal.election中的类: Elastic Job主服务器根节点名称的常量类.
execute(JobExecutionContext) - 类中的方法com.dangdang.ddframe.job.internal.job.AbstractElasticJob
execute() - 接口中的方法com.dangdang.ddframe.job.internal.storage.LeaderExecutionCallback: 节点选中之后执行的回调方法.
execute(CuratorTransactionFinal) - 接口中的方法com.dangdang.ddframe.job.internal.storage.TransactionExecutionCallback: 事务执行的回调方法.
executeInLeader(String, LeaderExecutionCallback) - 类中的方法com.dangdang.ddframe.job.internal.storage.JobNodeStorage: 在主节点执行操作.
executeInTransaction(TransactionExecutionCallback) - 类中的方法com.dangdang.ddframe.job.internal.storage.JobNodeStorage: 在事务中执行操作.
executeJob(JobExecutionMultipleShardingContext) - 类中的方法com.dangdang.ddframe.job.internal.job.AbstractElasticJob
executeJob(JobExecutionMultipleShardingContext) - 类中的方法com.dangdang.ddframe.job.internal.job.dataflow.AbstractDataFlowElasticJob
executeJob(JobExecutionMultipleShardingContext) - 类中的方法com.dangdang.ddframe.job.plugin.job.type.simple.AbstractSimpleElasticJob
ExecutionContextService - com.dangdang.ddframe.job.internal.execution中的类: 作业运行时上下文服务.
ExecutionContextService(CoordinatorRegistryCenter, JobConfiguration) - 类的构造器com.dangdang.ddframe.job.internal.execution.ExecutionContextService
ExecutionListenerManager - com.dangdang.ddframe.job.internal.execution中的类: 运行时状态监听管理器.
ExecutionListenerManager(CoordinatorRegistryCenter, JobConfiguration) - 类的构造器com.dangdang.ddframe.job.internal.execution.ExecutionListenerManager
ExecutionNode - com.dangdang.ddframe.job.internal.execution中的类: Elastic Job执行状态节点名称的常量类.
ExecutionNode(String) - 类的构造器com.dangdang.ddframe.job.internal.execution.ExecutionNode
ExecutionService - com.dangdang.ddframe.job.internal.execution中的类: 执行作业的服务.
ExecutionService(CoordinatorRegistryCenter, JobConfiguration) - 类的构造器com.dangdang.ddframe.job.internal.execution.ExecutionService

F

failoverIfNecessary() - 类中的方法com.dangdang.ddframe.job.internal.failover.FailoverService: 如果需要失效转移, 则设置作业失效转移.
failoverIfNecessary() - 类中的方法com.dangdang.ddframe.job.internal.schedule.JobFacade: 如果需要失效转移, 则设置作业失效转移.
FailoverListenerManager - com.dangdang.ddframe.job.internal.failover中的类: 失效转移监听管理器.
FailoverListenerManager(CoordinatorRegistryCenter, JobConfiguration) - 类的构造器com.dangdang.ddframe.job.internal.failover.FailoverListenerManager
FailoverNode - com.dangdang.ddframe.job.internal.failover中的类: Elastic Job失效转移节点名称的常量类.
FailoverNode(String) - 类的构造器com.dangdang.ddframe.job.internal.failover.FailoverNode
FailoverService - com.dangdang.ddframe.job.internal.failover中的类: 作业失效转移服务.
FailoverService(CoordinatorRegistryCenter, JobConfiguration) - 类的构造器com.dangdang.ddframe.job.internal.failover.FailoverService
fetchData(C) - 接口中的方法com.dangdang.ddframe.job.api.DataFlowElasticJob: 获取待处理的数据.
fillEphemeralJobNode(String, Object) - 类中的方法com.dangdang.ddframe.job.internal.storage.JobNodeStorage: 填充临时节点数据.
fillJobNodeIfNullOrOverwrite(String, Object) - 类中的方法com.dangdang.ddframe.job.internal.storage.JobNodeStorage: 如果节点不存在或允许覆盖则填充节点数据.
filterSensitiveIps(List<String>) - 类中的静态方法com.dangdang.ddframe.job.internal.util.SensitiveInfoUtils

G

get(String) - 接口中的方法com.dangdang.ddframe.reg.base.RegistryCenter: 获取注册数据.
get(String) - 类中的方法com.dangdang.ddframe.reg.zookeeper.ZookeeperRegistryCenter
getAllServers() - 类中的方法com.dangdang.ddframe.job.internal.server.ServerService: 获取所有的作业服务器列表.
getAvailableServers() - 类中的方法com.dangdang.ddframe.job.internal.server.ServerService: 获取可用的作业服务器列表.
getChildrenKeys(String) - 接口中的方法com.dangdang.ddframe.reg.base.CoordinatorRegistryCenter: 获取子节点名称集合.
getChildrenKeys(String) - 类中的方法com.dangdang.ddframe.reg.zookeeper.ZookeeperRegistryCenter
getConcurrentDataProcessThreadCount() - 类中的方法com.dangdang.ddframe.job.internal.config.ConfigurationService: 获取同时处理数据的并发线程数.
getConcurrentDataProcessThreadCount() - 类中的方法com.dangdang.ddframe.job.internal.schedule.JobFacade: 获取同时处理数据的并发线程数.
getCron() - 类中的方法com.dangdang.ddframe.job.internal.config.ConfigurationService: 获取作业启动时间的cron表达式.
getCron() - 类中的方法com.dangdang.ddframe.job.internal.schedule.SchedulerFacade: 获取作业启动时间的cron表达式.
getCurrentMillis() - 类中的方法com.dangdang.ddframe.job.internal.env.TimeService: 获取当前时间的毫秒数.
getDirectly(String) - 接口中的方法com.dangdang.ddframe.reg.base.CoordinatorRegistryCenter: 直接从注册中心而非本地缓存获取数据.
getDirectly(String) - 类中的方法com.dangdang.ddframe.reg.zookeeper.ZookeeperRegistryCenter
getExecutorService() - 接口中的方法com.dangdang.ddframe.job.api.DataFlowElasticJob: 获取线程执行服务.
getExecutorService() - 类中的方法com.dangdang.ddframe.job.internal.job.dataflow.AbstractDataFlowElasticJob
getFetchDataCount() - 类中的方法com.dangdang.ddframe.job.internal.config.ConfigurationService: 获取每次抓取的数据量.
getFullPath(String) - 类中的方法com.dangdang.ddframe.job.internal.storage.JobNodePath: 获取节点全路径.
getHostName() - 类中的方法com.dangdang.ddframe.job.internal.env.LocalHostService: 获取本机Host名称.
getInstance() - 类中的静态方法com.dangdang.ddframe.job.internal.schedule.JobRegistry: 获取作业注册表实例.
getInstance() - 类中的静态方法com.dangdang.ddframe.reg.zookeeper.NestedZookeeperServers: 获取单例实例.
getIp() - 类中的方法com.dangdang.ddframe.job.internal.env.LocalHostService: 获取本机IP地址.
getItemByExecutionFailoverPath(String) - 类中的方法com.dangdang.ddframe.job.internal.failover.FailoverNode: 根据失效转移执行路径获取分片项.
getItemByRunningItemPath(String) - 类中的方法com.dangdang.ddframe.job.internal.execution.ExecutionNode: 根据运行中的分片路径获取分片项.
getItemNode(int) - 类中的静态方法com.dangdang.ddframe.job.internal.offset.OffsetNode: 获取分片数据处理位置节点路径.
getJobExecutionShardingContext(List<Integer>) - 类中的方法com.dangdang.ddframe.job.internal.execution.ExecutionContextService: 获取当前作业服务器运行时分片上下文.
getJobInstance(String) - 类中的方法com.dangdang.ddframe.job.internal.schedule.JobRegistry: 获取作业实例.
getJobName() - 类中的方法com.dangdang.ddframe.job.internal.config.ConfigurationService: 获取作业名称.
getJobName() - 类中的方法com.dangdang.ddframe.job.internal.schedule.JobFacade: 获取作业名称.
getJobNodeChildrenKeys(String) - 类中的方法com.dangdang.ddframe.job.internal.storage.JobNodeStorage: 获取作业节点子节点名称列表.
getJobNodeData(String) - 类中的方法com.dangdang.ddframe.job.internal.storage.JobNodeStorage: 获取作业节点数据.
getJobNodeDataDirectly(String) - 类中的方法com.dangdang.ddframe.job.internal.storage.JobNodeStorage: 直接从注册中心而非本地缓存获取作业节点数据.
getJobParameter() - 类中的方法com.dangdang.ddframe.job.internal.config.ConfigurationService: 获取作业自定义参数.
getJobScheduler(String) - 类中的方法com.dangdang.ddframe.job.internal.schedule.JobRegistry: 获取作业控制器.
getJobShardingStrategyClass() - 类中的方法com.dangdang.ddframe.job.internal.config.ConfigurationService: 获取作业分片策略实现类全路径.
getLocalHostFailoverItems() - 类中的方法com.dangdang.ddframe.job.internal.failover.FailoverService: 获取运行在本作业服务器的失效转移序列号.
getLocalHostShardingItems() - 类中的方法com.dangdang.ddframe.job.internal.sharding.ShardingService: 获取运行在本作业服务器的分片序列号.
getLocalHostTakeOffItems() - 类中的方法com.dangdang.ddframe.job.internal.failover.FailoverService: 获取运行在本作业服务器的被失效转移的序列号.
getMisfiredJobItems(List<Integer>) - 类中的方法com.dangdang.ddframe.job.internal.execution.ExecutionService: 获取标记被错过执行的任务分片项.
getMonitorPort() - 类中的方法com.dangdang.ddframe.job.internal.config.ConfigurationService: 获取作业监控端口.
getName() - 类中的方法com.dangdang.ddframe.job.internal.schedule.JobTriggerListener
getNextFireTime() - 类中的方法com.dangdang.ddframe.job.api.JobScheduler: 获取下次作业触发时间.
getOffsets(List<Integer>) - 类中的方法com.dangdang.ddframe.job.internal.offset.OffsetService: 获取数据分片项和数据处理位置Map.
getProcessCountIntervalSeconds() - 类中的方法com.dangdang.ddframe.job.internal.config.ConfigurationService: 获取统计作业处理数据数量的间隔时间.
getProcessFailureCount(String) - 类中的静态方法com.dangdang.ddframe.job.internal.statistics.ProcessCountStatistics: 获取本作业服务器处理数据错误的数量.
getProcessSuccessCount(String) - 类中的静态方法com.dangdang.ddframe.job.internal.statistics.ProcessCountStatistics: 获取本作业服务器处理数据正确的数量.
getRawCache(String) - 接口中的方法com.dangdang.ddframe.reg.base.CoordinatorRegistryCenter: 获取注册中心数据缓存对象.
getRawCache(String) - 类中的方法com.dangdang.ddframe.reg.zookeeper.ZookeeperRegistryCenter
getRawClient() - 接口中的方法com.dangdang.ddframe.reg.base.RegistryCenter: 直接获取操作注册中心的原生客户端.
getRawClient() - 类中的方法com.dangdang.ddframe.reg.zookeeper.ZookeeperRegistryCenter
getRegistryCenterTime() - 类中的方法com.dangdang.ddframe.job.internal.storage.JobNodeStorage: 获取注册中心当前时间.
getRegistryCenterTime(String) - 接口中的方法com.dangdang.ddframe.reg.base.RegistryCenter: 获取注册中心当前时间.
getRegistryCenterTime(String) - 类中的方法com.dangdang.ddframe.reg.zookeeper.ZookeeperRegistryCenter
getRunningNode(int) - 类中的静态方法com.dangdang.ddframe.job.internal.execution.ExecutionNode: 获取作业运行状态节点路径.
getShardingContext() - 类中的方法com.dangdang.ddframe.job.internal.schedule.JobFacade: 获取当前作业服务器运行时分片上下文.
getShardingItemParameters() - 类中的方法com.dangdang.ddframe.job.internal.config.ConfigurationService: 获取分片序列号和个性化参数对照表.
getShardingTotalCount() - 类中的方法com.dangdang.ddframe.job.internal.config.ConfigurationService: 获取作业分片总数.
getStrategy(String) - 类中的静态方法com.dangdang.ddframe.job.internal.sharding.strategy.JobShardingStrategyFactory: 获取作业分片策略实例.
GuaranteeListenerManager - com.dangdang.ddframe.job.internal.guarantee中的类: 保证分布式任务全部开始和结束状态监听管理器.
GuaranteeListenerManager(CoordinatorRegistryCenter, JobConfiguration, List<ElasticJobListener>) - 类的构造器com.dangdang.ddframe.job.internal.guarantee.GuaranteeListenerManager
GuaranteeNode - com.dangdang.ddframe.job.internal.guarantee中的类: 保证分布式任务全部开始和结束状态节点名称的常量类.
GuaranteeService - com.dangdang.ddframe.job.internal.guarantee中的类: 保证分布式任务全部开始和结束状态的服务.
GuaranteeService(CoordinatorRegistryCenter, JobConfiguration) - 类的构造器com.dangdang.ddframe.job.internal.guarantee.GuaranteeService

H

handleException(Exception) - 类中的静态方法com.dangdang.ddframe.reg.exception.RegExceptionHandler: 处理掉中断和连接失效异常并继续抛出RegException.
handleJobExecutionException(JobExecutionException) - 接口中的方法com.dangdang.ddframe.job.api.ElasticJob: 处理作业执行时异常.
handleJobExecutionException(JobExecutionException) - 类中的方法com.dangdang.ddframe.job.internal.job.AbstractElasticJob
handleJobExecutionException(JobExecutionException) - 类中的方法com.dangdang.ddframe.job.internal.job.dataflow.AbstractDataFlowElasticJob
handleJobExecutionException(JobExecutionException) - 类中的方法com.dangdang.ddframe.job.plugin.job.type.simple.AbstractSimpleElasticJob
hasLeader() - 类中的方法com.dangdang.ddframe.job.internal.election.LeaderElectionService: 判断是否已经有主节点.
hasRunningItems(List<Integer>) - 类中的方法com.dangdang.ddframe.job.internal.execution.ExecutionService: 判断分片项中是否还有执行中的作业.
hasRunningItems() - 类中的方法com.dangdang.ddframe.job.internal.execution.ExecutionService: 判断是否还有执行中的作业.

I

incrementProcessFailureCount(String) - 类中的静态方法com.dangdang.ddframe.job.internal.statistics.ProcessCountStatistics: 增加本作业服务器处理数据错误的数量.
incrementProcessFailureCount(String, int) - 类中的静态方法com.dangdang.ddframe.job.internal.statistics.ProcessCountStatistics: 增加本作业服务器处理数据错误的数量.
incrementProcessSuccessCount(String) - 类中的静态方法com.dangdang.ddframe.job.internal.statistics.ProcessCountStatistics: 增加本作业服务器处理数据正确的数量.
incrementProcessSuccessCount(String, int) - 类中的静态方法com.dangdang.ddframe.job.internal.statistics.ProcessCountStatistics: 增加本作业服务器处理数据正确的数量.
IndividualProcessable<T,C extends AbstractJobExecutionShardingContext> - com.dangdang.ddframe.job.internal.job.dataflow中的接口: 逐条处理数据的接口.
init() - 类中的方法com.dangdang.ddframe.job.api.JobScheduler: 初始化作业.
init() - 接口中的方法com.dangdang.ddframe.reg.base.RegistryCenter: 初始化注册中心.
init() - 类中的方法com.dangdang.ddframe.reg.zookeeper.ZookeeperRegistryCenter
isAllCompleted() - 类中的方法com.dangdang.ddframe.job.internal.guarantee.GuaranteeService: 判断是否所有的任务均执行完毕.
isAllStarted() - 类中的方法com.dangdang.ddframe.job.internal.guarantee.GuaranteeService: 判断是否所有的任务均启动完毕.
isCompleted(int) - 类中的方法com.dangdang.ddframe.job.internal.execution.ExecutionService: 判断该分片是否已完成.
isCronPath(String) - 类中的方法com.dangdang.ddframe.job.internal.config.ConfigurationNode: 判断是否为作业调度配置路径.
isEligibleForJobRunning() - 类中的方法com.dangdang.ddframe.job.internal.schedule.JobFacade: 判断作业是否符合继续运行的条件.
isExecuteMisfired(List<Integer>) - 类中的方法com.dangdang.ddframe.job.internal.schedule.JobFacade: 判断作业是否需要执行错过的任务.
isExisted(String) - 接口中的方法com.dangdang.ddframe.reg.base.RegistryCenter: 获取数据是否存在.
isExisted(String) - 类中的方法com.dangdang.ddframe.reg.zookeeper.ZookeeperRegistryCenter
isFailover() - 类中的方法com.dangdang.ddframe.job.internal.config.ConfigurationService: 获取是否开启失效转移.
isFailoverPath(String) - 类中的方法com.dangdang.ddframe.job.internal.config.ConfigurationNode: 判断是否为失效转移设置路径.
isJobNodeExisted(String) - 类中的方法com.dangdang.ddframe.job.internal.storage.JobNodeStorage: 判断作业节点是否存在.
isJobStoppedManually() - 类中的方法com.dangdang.ddframe.job.internal.server.ServerService: 判断是否是手工停止的作业.
isLeader() - 类中的方法com.dangdang.ddframe.job.internal.election.LeaderElectionService: 判断当前节点是否是主节点.
isMisfire() - 类中的方法com.dangdang.ddframe.job.internal.config.ConfigurationService: 获取是否开启misfire.
isMisfire() - 类中的方法com.dangdang.ddframe.job.internal.schedule.SchedulerFacade: 获取是否开启misfire.
isMonitorExecution() - 类中的方法com.dangdang.ddframe.job.internal.config.ConfigurationService: 获取是否监控作业运行时状态.
isMonitorExecutionPath(String) - 类中的方法com.dangdang.ddframe.job.internal.config.ConfigurationNode: 判断是否为监控作业执行时状态路径.
isNeedSharding() - 类中的方法com.dangdang.ddframe.job.internal.schedule.JobFacade: 判断是否需要重分片.
isNeedSharding() - 类中的方法com.dangdang.ddframe.job.internal.sharding.ShardingService: 判断是否需要重分片.
isServerDisabledPath(String) - 类中的方法com.dangdang.ddframe.job.internal.server.ServerNode: 判断给定路径是否为作业服务器禁用路径.
isServerReady() - 类中的方法com.dangdang.ddframe.job.internal.server.ServerService: 判断当前服务器是否是等待执行的状态.
isServerStatusPath(String) - 类中的方法com.dangdang.ddframe.job.internal.server.ServerNode: 判断给定路径是否为作业服务器状态路径.
isShardingTotalCountPath(String) - 类中的方法com.dangdang.ddframe.job.internal.config.ConfigurationNode: 判断是否为作业分片总数路径.
isStreamingProcess() - 类中的方法com.dangdang.ddframe.job.api.AbstractPerpetualElasticJob: 已过时。
isStreamingProcess() - 类中的方法com.dangdang.ddframe.job.api.AbstractSequencePerpetualElasticJob: 已过时。
isStreamingProcess() - 接口中的方法com.dangdang.ddframe.job.api.DataFlowElasticJob: 配置是否流式处理数据.
isUseNestedZookeeper() - 类中的方法com.dangdang.ddframe.reg.zookeeper.ZookeeperConfiguration: 判断是否需要开启内嵌Zookeeper.
ItemUtils - com.dangdang.ddframe.job.internal.util中的类: 分片项工具类.
ItemUtils() - 类的构造器com.dangdang.ddframe.job.internal.util.ItemUtils

J

JobConfiguration - com.dangdang.ddframe.job.api中的类: 作业配置信息.
JobConfiguration() - 类的构造器com.dangdang.ddframe.job.api.JobConfiguration
JobConflictException - com.dangdang.ddframe.job.exception中的异常错误: 作业冲突抛出的异常.
JobConflictException(String, String, String) - 异常错误的构造器com.dangdang.ddframe.job.exception.JobConflictException
JobController - com.dangdang.ddframe.job.schedule中的类: 已过时。
.
JobController(CoordinatorRegistryCenter, JobConfiguration) - 类的构造器com.dangdang.ddframe.job.schedule.JobController: 已过时。
JobException - com.dangdang.ddframe.job.exception中的异常错误: 分布式作业抛出的异常基类.
JobException(String, Object...) - 异常错误的构造器com.dangdang.ddframe.job.exception.JobException
JobException(Exception) - 异常错误的构造器com.dangdang.ddframe.job.exception.JobException
JobExecutionMultipleShardingContext - com.dangdang.ddframe.job.api中的类: 作业运行时多片分片上下文.
JobExecutionMultipleShardingContext() - 类的构造器com.dangdang.ddframe.job.api.JobExecutionMultipleShardingContext
JobExecutionSingleShardingContext - com.dangdang.ddframe.job.api中的类: 作业运行时单片分片上下文.
JobExecutionSingleShardingContext() - 类的构造器com.dangdang.ddframe.job.api.JobExecutionSingleShardingContext
JobFacade - com.dangdang.ddframe.job.internal.schedule中的类: 为调度器提供内部服务的门面类.
JobFacade(CoordinatorRegistryCenter, JobConfiguration, List<ElasticJobListener>) - 类的构造器com.dangdang.ddframe.job.internal.schedule.JobFacade
JobNodePath - com.dangdang.ddframe.job.internal.storage中的类: 作业节点路径类.
JobNodePath(String) - 类的构造器com.dangdang.ddframe.job.internal.storage.JobNodePath
JobNodeStorage - com.dangdang.ddframe.job.internal.storage中的类: 作业节点数据访问类.
JobNodeStorage(CoordinatorRegistryCenter, JobConfiguration) - 类的构造器com.dangdang.ddframe.job.internal.storage.JobNodeStorage
JobOperationListenerManager - com.dangdang.ddframe.job.internal.server中的类: 作业控制监听管理器.
JobOperationListenerManager(CoordinatorRegistryCenter, JobConfiguration) - 类的构造器com.dangdang.ddframe.job.internal.server.JobOperationListenerManager
JobRegistry - com.dangdang.ddframe.job.internal.schedule中的类: 作业注册表.
JobRegistry() - 类的构造器com.dangdang.ddframe.job.internal.schedule.JobRegistry
JobScheduler - com.dangdang.ddframe.job.api中的类: 作业调度器.
JobScheduler(CoordinatorRegistryCenter, JobConfiguration, ElasticJobListener...) - 类的构造器com.dangdang.ddframe.job.api.JobScheduler
JobShardingStrategy - com.dangdang.ddframe.job.internal.sharding.strategy中的接口: 作业分片策略.
JobShardingStrategyClassConfigurationException - com.dangdang.ddframe.job.exception中的异常错误: 作业分片策略类配置错误抛出的异常.
JobShardingStrategyClassConfigurationException(Exception) - 异常错误的构造器com.dangdang.ddframe.job.exception.JobShardingStrategyClassConfigurationException
JobShardingStrategyFactory - com.dangdang.ddframe.job.internal.sharding.strategy中的类: 作业分片策略工厂.
JobShardingStrategyFactory() - 类的构造器com.dangdang.ddframe.job.internal.sharding.strategy.JobShardingStrategyFactory
JobShardingStrategyOption - com.dangdang.ddframe.job.internal.sharding.strategy中的类: 作业分片策略选项.
JobShardingStrategyOption() - 类的构造器com.dangdang.ddframe.job.internal.sharding.strategy.JobShardingStrategyOption
JobTimeoutException - com.dangdang.ddframe.job.exception中的异常错误: 作业超时抛出的异常.
JobTimeoutException(long) - 异常错误的构造器com.dangdang.ddframe.job.exception.JobTimeoutException: 作业超时抛出的异常.
JobTriggerListener - com.dangdang.ddframe.job.internal.schedule中的类: 作业触发监听器.
JobTriggerListener() - 类的构造器com.dangdang.ddframe.job.internal.schedule.JobTriggerListener

L

leaderElection() - 类中的方法com.dangdang.ddframe.job.internal.election.LeaderElectionService: 选举主节点.
LeaderElectionService - com.dangdang.ddframe.job.internal.election中的类: 选举主节点的服务.
LeaderElectionService(CoordinatorRegistryCenter, JobConfiguration) - 类的构造器com.dangdang.ddframe.job.internal.election.LeaderElectionService
LeaderExecutionCallback - com.dangdang.ddframe.job.internal.storage中的接口: 主节点执行操作的回调接口.
listen() - 类中的方法com.dangdang.ddframe.job.internal.monitor.MonitorService: 初始化作业监听服务.
ListenerManager - com.dangdang.ddframe.job.internal.listener中的类: 作业注册中心的监听器管理者.
ListenerManager(CoordinatorRegistryCenter, JobConfiguration, List<ElasticJobListener>) - 类的构造器com.dangdang.ddframe.job.internal.listener.ListenerManager
LocalHostService - com.dangdang.ddframe.job.internal.env中的类: 获取真实本机网络的服务.
LocalHostService() - 类的构造器com.dangdang.ddframe.job.internal.env.LocalHostService
LocalPropertiesFileNotFoundException - com.dangdang.ddframe.reg.exception中的异常错误: 找不到本地属性文件所抛出的异常.
LocalPropertiesFileNotFoundException(String) - 异常错误的构造器com.dangdang.ddframe.reg.exception.LocalPropertiesFileNotFoundException
LocalPropertiesFileNotFoundException(IOException) - 异常错误的构造器com.dangdang.ddframe.reg.exception.LocalPropertiesFileNotFoundException

M

misfireIfNecessary(List<Integer>) - 类中的方法com.dangdang.ddframe.job.internal.execution.ExecutionService: 如果满足条件，设置任务被错过执行的标记.
misfireIfNecessary(List<Integer>) - 类中的方法com.dangdang.ddframe.job.internal.schedule.JobFacade: 设置任务被错过执行的标记.
MonitorService - com.dangdang.ddframe.job.internal.monitor中的类: 作业监控服务.
MonitorService(CoordinatorRegistryCenter, JobConfiguration) - 类的构造器com.dangdang.ddframe.job.internal.monitor.MonitorService

N

NestedZookeeperServers - com.dangdang.ddframe.reg.zookeeper中的类: 内嵌的Zookeeper服务器.
NestedZookeeperServers() - 类的构造器com.dangdang.ddframe.reg.zookeeper.NestedZookeeperServers
newJobTriggerListener() - 类中的方法com.dangdang.ddframe.job.internal.schedule.SchedulerFacade: 获取作业触发监听器.
notifyWaitingTaskComplete() - 类中的方法com.dangdang.ddframe.job.api.listener.AbstractDistributeOnceElasticJobListener: 通知任务结束.
notifyWaitingTaskStart() - 类中的方法com.dangdang.ddframe.job.api.listener.AbstractDistributeOnceElasticJobListener: 通知任务开始.

O

OdevitySortByNameJobShardingStrategy - com.dangdang.ddframe.job.plugin.sharding.strategy中的类: 根据作业名的哈希值奇偶数决定IP升降序算法的分片策略.
OdevitySortByNameJobShardingStrategy() - 类的构造器com.dangdang.ddframe.job.plugin.sharding.strategy.OdevitySortByNameJobShardingStrategy
OffsetNode - com.dangdang.ddframe.job.internal.offset中的类: Elastic Job数据处理位置节点名称的常量类.
OffsetNode() - 类的构造器com.dangdang.ddframe.job.internal.offset.OffsetNode
OffsetService - com.dangdang.ddframe.job.internal.offset中的类: 数据处理位置服务.
OffsetService(CoordinatorRegistryCenter, JobConfiguration) - 类的构造器com.dangdang.ddframe.job.internal.offset.OffsetService

P

persist(String, String) - 接口中的方法com.dangdang.ddframe.reg.base.RegistryCenter: 持久化注册数据.
persist(String, String) - 类中的方法com.dangdang.ddframe.reg.zookeeper.ZookeeperRegistryCenter
persistEphemeral(String, String) - 接口中的方法com.dangdang.ddframe.reg.base.CoordinatorRegistryCenter: 持久化临时注册数据.
persistEphemeral(String, String) - 类中的方法com.dangdang.ddframe.reg.zookeeper.ZookeeperRegistryCenter
persistEphemeralSequential(String) - 接口中的方法com.dangdang.ddframe.reg.base.CoordinatorRegistryCenter: 持久化临时顺序注册数据.
persistEphemeralSequential(String) - 类中的方法com.dangdang.ddframe.reg.zookeeper.ZookeeperRegistryCenter
persistJobConfiguration() - 类中的方法com.dangdang.ddframe.job.internal.config.ConfigurationService: 持久化分布式作业配置信息.
persistProcessFailureCount(int) - 类中的方法com.dangdang.ddframe.job.internal.server.ServerService: 持久化统计处理数据失败的数量的数据.
persistProcessSuccessCount(int) - 类中的方法com.dangdang.ddframe.job.internal.server.ServerService: 持久化统计处理数据成功的数量的数据.
persistServerOnline() - 类中的方法com.dangdang.ddframe.job.internal.server.ServerService: 持久化作业服务器上线相关信息.
prepareEnvironments(Properties) - 类中的方法com.dangdang.ddframe.job.api.JobScheduler
process(JobExecutionMultipleShardingContext) - 类中的方法com.dangdang.ddframe.job.plugin.job.type.simple.AbstractSimpleElasticJob: 执行作业.
ProcessCountJob - com.dangdang.ddframe.job.internal.statistics中的类: 统计处理数据数量的作业.
ProcessCountJob(CoordinatorRegistryCenter, JobConfiguration) - 类的构造器com.dangdang.ddframe.job.internal.statistics.ProcessCountJob
ProcessCountStatistics - com.dangdang.ddframe.job.internal.statistics中的类: 统计处理数据数量的类.
ProcessCountStatistics() - 类的构造器com.dangdang.ddframe.job.internal.statistics.ProcessCountStatistics
processData(C, List<T>) - 接口中的方法com.dangdang.ddframe.job.internal.job.dataflow.BatchProcessable: 批量处理数据.
processData(C, T) - 接口中的方法com.dangdang.ddframe.job.internal.job.dataflow.IndividualProcessable: 处理数据.
processDataWithStatistics(C, List<T>) - 类中的方法com.dangdang.ddframe.job.internal.job.dataflow.AbstractBatchDataFlowElasticJob
processDataWithStatistics(C, List<T>) - 类中的方法com.dangdang.ddframe.job.internal.job.dataflow.AbstractDataFlowElasticJob
processDataWithStatistics(C, List<T>) - 类中的方法com.dangdang.ddframe.job.internal.job.dataflow.AbstractIndividualDataFlowElasticJob
processServerShutdown() - 类中的方法com.dangdang.ddframe.job.internal.server.ServerService: 处理服务器关机的相关信息.

R

RegException - com.dangdang.ddframe.reg.exception中的异常错误: 注册中心模块抛出的异常基类.
RegException(String, Object...) - 异常错误的构造器com.dangdang.ddframe.reg.exception.RegException
RegException(Exception) - 异常错误的构造器com.dangdang.ddframe.reg.exception.RegException
RegExceptionHandler - com.dangdang.ddframe.reg.exception中的类: 抛出RegException的异常处理类.
RegExceptionHandler() - 类的构造器com.dangdang.ddframe.reg.exception.RegExceptionHandler
registerComplete(Collection<Integer>) - 类中的方法com.dangdang.ddframe.job.internal.guarantee.GuaranteeService: 根据分片项注册任务完成运行.
registerJobBegin(JobExecutionMultipleShardingContext) - 类中的方法com.dangdang.ddframe.job.internal.execution.ExecutionService: 注册作业启动信息.
registerJobBegin(JobExecutionMultipleShardingContext) - 类中的方法com.dangdang.ddframe.job.internal.schedule.JobFacade: 注册作业启动信息.
registerJobCompleted(JobExecutionMultipleShardingContext) - 类中的方法com.dangdang.ddframe.job.internal.execution.ExecutionService: 注册作业完成信息.
registerJobCompleted(JobExecutionMultipleShardingContext) - 类中的方法com.dangdang.ddframe.job.internal.schedule.JobFacade: 注册作业完成信息.
registerStart(Collection<Integer>) - 类中的方法com.dangdang.ddframe.job.internal.guarantee.GuaranteeService: 根据分片项注册任务开始运行.
registerStartUpInfo() - 类中的方法com.dangdang.ddframe.job.internal.schedule.SchedulerFacade: 注册Elastic-Job启动信息.
RegistryCenter - com.dangdang.ddframe.reg.base中的接口: 注册中心.
releaseJobResource() - 类中的方法com.dangdang.ddframe.job.internal.schedule.SchedulerFacade: 释放作业占用的资源.
remove(String) - 接口中的方法com.dangdang.ddframe.reg.base.RegistryCenter: 删除注册数据.
remove(String) - 类中的方法com.dangdang.ddframe.reg.zookeeper.ZookeeperRegistryCenter
removeExecutionInfo() - 类中的方法com.dangdang.ddframe.job.internal.execution.ExecutionService: 删除作业执行时信息.
removeFailoverInfo() - 类中的方法com.dangdang.ddframe.job.internal.failover.FailoverService: 删除作业失效转移信息.
removeJobNodeIfExisted(String) - 类中的方法com.dangdang.ddframe.job.internal.storage.JobNodeStorage: 删除作业节点.
replaceJobNode(String, Object) - 类中的方法com.dangdang.ddframe.job.internal.storage.JobNodeStorage: 替换作业节点数据.
rescheduleJob(String) - 类中的方法com.dangdang.ddframe.job.api.JobScheduler: 重新调度作业.
reset(String) - 类中的静态方法com.dangdang.ddframe.job.internal.statistics.ProcessCountStatistics: 重置统计信息.
resumeJob() - 类中的方法com.dangdang.ddframe.job.api.JobScheduler: 恢复作业.
ROOT - 类中的静态变量com.dangdang.ddframe.job.internal.election.ElectionNode: Elastic Job主服务器根节点.
ROOT - 类中的静态变量com.dangdang.ddframe.job.internal.execution.ExecutionNode: 执行状态根节点.
ROOT - 类中的静态变量com.dangdang.ddframe.job.internal.server.ServerNode: 作业服务器信息根节点.
RotateServerByNameJobShardingStrategy - com.dangdang.ddframe.job.plugin.sharding.strategy中的类: 根据作业名的哈希值对服务器列表进行轮转的分片策略.
RotateServerByNameJobShardingStrategy() - 类的构造器com.dangdang.ddframe.job.plugin.sharding.strategy.RotateServerByNameJobShardingStrategy
run() - 类中的方法com.dangdang.ddframe.job.internal.statistics.ProcessCountJob

S

SchedulerFacade - com.dangdang.ddframe.job.internal.schedule中的类: 为调度器提供内部服务的门面类.
SchedulerFacade(CoordinatorRegistryCenter, JobConfiguration, List<ElasticJobListener>) - 类的构造器com.dangdang.ddframe.job.internal.schedule.SchedulerFacade
SensitiveInfoUtils - com.dangdang.ddframe.job.internal.util中的类: 敏感信息过滤工具类.
SensitiveInfoUtils() - 类的构造器com.dangdang.ddframe.job.internal.util.SensitiveInfoUtils
ServerNode - com.dangdang.ddframe.job.internal.server中的类: Elastic Job服务器节点名称的常量类.
ServerNode(String) - 类的构造器com.dangdang.ddframe.job.internal.server.ServerNode
ServerService - com.dangdang.ddframe.job.internal.server中的类: 作业服务器节点服务.
ServerService(CoordinatorRegistryCenter, JobConfiguration) - 类的构造器com.dangdang.ddframe.job.internal.server.ServerService
ServerStatus - com.dangdang.ddframe.job.internal.server中的枚举: 服务器状态.
setCrashedFailoverFlag(int) - 类中的方法com.dangdang.ddframe.job.internal.failover.FailoverService: 设置失效的分片项标记.
setField(String, Object) - 类中的方法com.dangdang.ddframe.job.api.JobScheduler: 设置作业字段属性.
setJobFacade(JobFacade) - 类中的方法com.dangdang.ddframe.job.internal.job.AbstractElasticJob
setMisfire(List<Integer>) - 类中的方法com.dangdang.ddframe.job.internal.execution.ExecutionService: 设置任务被错过执行的标记.
setNeedFixExecutionInfoFlag() - 类中的方法com.dangdang.ddframe.job.internal.execution.ExecutionService: 设置修复运行时分片信息标记的状态标志位.
setReshardingFlag() - 类中的方法com.dangdang.ddframe.job.internal.sharding.ShardingService: 设置需要重新分片的标记.
sharding(List<String>, JobShardingStrategyOption) - 接口中的方法com.dangdang.ddframe.job.internal.sharding.strategy.JobShardingStrategy: 进行作业分片.
sharding(List<String>, JobShardingStrategyOption) - 类中的方法com.dangdang.ddframe.job.plugin.sharding.strategy.AverageAllocationJobShardingStrategy
sharding(List<String>, JobShardingStrategyOption) - 类中的方法com.dangdang.ddframe.job.plugin.sharding.strategy.OdevitySortByNameJobShardingStrategy
sharding(List<String>, JobShardingStrategyOption) - 类中的方法com.dangdang.ddframe.job.plugin.sharding.strategy.RotateServerByNameJobShardingStrategy
shardingIfNecessary() - 类中的方法com.dangdang.ddframe.job.internal.sharding.ShardingService: 如果需要分片且当前节点为主节点, 则作业分片.
ShardingItemParametersException - com.dangdang.ddframe.job.exception中的异常错误: 分片序列号和个性化参数格式不正确抛出的异常.
ShardingItemParametersException(String, Object...) - 异常错误的构造器com.dangdang.ddframe.job.exception.ShardingItemParametersException
ShardingListenerManager - com.dangdang.ddframe.job.internal.sharding中的类: 分片监听管理器.
ShardingListenerManager(CoordinatorRegistryCenter, JobConfiguration) - 类的构造器com.dangdang.ddframe.job.internal.sharding.ShardingListenerManager
ShardingService - com.dangdang.ddframe.job.internal.sharding中的类: 作业分片服务.
ShardingService(CoordinatorRegistryCenter, JobConfiguration) - 类的构造器com.dangdang.ddframe.job.internal.sharding.ShardingService
shutdown() - 类中的方法com.dangdang.ddframe.job.api.JobScheduler: 关闭调度器.
sleep(long) - 类中的静态方法com.dangdang.ddframe.job.internal.util.BlockUtils
start() - 类中的方法com.dangdang.ddframe.job.internal.config.ConfigurationListenerManager
start() - 类中的方法com.dangdang.ddframe.job.internal.election.ElectionListenerManager
start() - 类中的方法com.dangdang.ddframe.job.internal.execution.ExecutionListenerManager
start() - 类中的方法com.dangdang.ddframe.job.internal.failover.FailoverListenerManager
start() - 类中的方法com.dangdang.ddframe.job.internal.guarantee.GuaranteeListenerManager
start() - 类中的方法com.dangdang.ddframe.job.internal.listener.AbstractListenerManager: 开启监听器.
start() - 类中的方法com.dangdang.ddframe.job.internal.server.JobOperationListenerManager
start() - 类中的方法com.dangdang.ddframe.job.internal.sharding.ShardingListenerManager
startAllListeners() - 类中的方法com.dangdang.ddframe.job.internal.listener.ListenerManager: 开启所有监听器.
startProcessCountJob() - 类中的方法com.dangdang.ddframe.job.internal.statistics.StatisticsService: 开启统计处理数据数量的作业.
startServerIfNotStarted(int, String) - 类中的方法com.dangdang.ddframe.reg.zookeeper.NestedZookeeperServers: 启动内嵌的Zookeeper服务.
StatisticsService - com.dangdang.ddframe.job.internal.statistics中的类: 作业统计信息服务.
StatisticsService(CoordinatorRegistryCenter, JobConfiguration) - 类的构造器com.dangdang.ddframe.job.internal.statistics.StatisticsService
stopJob() - 类中的方法com.dangdang.ddframe.job.api.JobScheduler: 停止作业.
stopProcessCountJob() - 类中的方法com.dangdang.ddframe.job.internal.statistics.StatisticsService: 停止统计处理数据数量的作业.

T

TimeDiffIntolerableException - com.dangdang.ddframe.job.exception中的异常错误: 本机与注册中心的时间误差超过容忍范围抛出的异常.
TimeDiffIntolerableException(int, int) - 异常错误的构造器com.dangdang.ddframe.job.exception.TimeDiffIntolerableException
TimeService - com.dangdang.ddframe.job.internal.env中的类: 获取时间的服务.
TimeService() - 类的构造器com.dangdang.ddframe.job.internal.env.TimeService
toItemList(String) - 类中的静态方法com.dangdang.ddframe.job.internal.util.ItemUtils: 根据分片项字符串获取分片项列表.
toItemsString(List<Integer>) - 类中的静态方法com.dangdang.ddframe.job.internal.util.ItemUtils: 根据分片项列表获取分片项字符串.
toString() - 类中的方法com.dangdang.ddframe.job.api.JobExecutionMultipleShardingContext
TransactionExecutionCallback - com.dangdang.ddframe.job.internal.storage中的接口: 事务执行操作的回调接口.
triggerJob() - 类中的方法com.dangdang.ddframe.job.api.JobScheduler: 立刻启动作业.
triggerMisfired(Trigger) - 类中的方法com.dangdang.ddframe.job.internal.schedule.JobTriggerListener

U

update(String, String) - 接口中的方法com.dangdang.ddframe.reg.base.RegistryCenter: 更新注册数据.
update(String, String) - 类中的方法com.dangdang.ddframe.reg.zookeeper.ZookeeperRegistryCenter
updateFailoverComplete(List<Integer>) - 类中的方法com.dangdang.ddframe.job.internal.failover.FailoverService: 更新执行完毕失效转移的分片项状态.
updateJobNode(String, Object) - 类中的方法com.dangdang.ddframe.job.internal.storage.JobNodeStorage: 更新节点数据.
updateOffset(int, String) - 接口中的方法com.dangdang.ddframe.job.api.DataFlowElasticJob: 更新数据处理位置.
updateOffset(int, String) - 类中的方法com.dangdang.ddframe.job.internal.job.dataflow.AbstractDataFlowElasticJob
updateOffset(int, String) - 类中的方法com.dangdang.ddframe.job.internal.offset.OffsetService: 更新数据处理位置.
updateOffset(int, String) - 类中的方法com.dangdang.ddframe.job.internal.schedule.JobFacade: 更新数据处理位置.
updateServerStatus(ServerStatus) - 类中的方法com.dangdang.ddframe.job.internal.server.ServerService: 在开始或结束执行作业时更新服务器状态.

V

valueOf(String) - 枚举中的静态方法com.dangdang.ddframe.job.internal.job.dataflow.DataFlowType: 返回带有指定名称的该类型的枚举常量。
valueOf(String) - 枚举中的静态方法com.dangdang.ddframe.job.internal.server.ServerStatus: 返回带有指定名称的该类型的枚举常量。
values() - 枚举中的静态方法com.dangdang.ddframe.job.internal.job.dataflow.DataFlowType: 按照声明该枚举类型的常量的顺序, 返回包含这些常量的数组。
values() - 枚举中的静态方法com.dangdang.ddframe.job.internal.server.ServerStatus: 按照声明该枚举类型的常量的顺序, 返回包含这些常量的数组。

W

waitingShortTime() - 类中的静态方法com.dangdang.ddframe.job.internal.util.BlockUtils

Z

ZookeeperConfiguration - com.dangdang.ddframe.reg.zookeeper中的类: 基于Zookeeper的注册中心配置.
ZookeeperConfiguration(String, String, int, int, int) - 类的构造器com.dangdang.ddframe.reg.zookeeper.ZookeeperConfiguration: 包含了必需属性的构造器.
ZookeeperRegistryCenter - com.dangdang.ddframe.reg.zookeeper中的类: 基于Zookeeper的注册中心.
ZookeeperRegistryCenter(ZookeeperConfiguration) - 类的构造器com.dangdang.ddframe.reg.zookeeper.ZookeeperRegistryCenter

A B C D E F G H I J L M N O P R S T U V W Z