org.apache.shardingsphere.elasticjob.infra.handler.sharding.impl

类 AverageAllocationJobShardingStrategy

java.lang.Object

org.apache.shardingsphere.elasticjob.infra.handler.sharding.impl.AverageAllocationJobShardingStrategy

所有已实现的接口:

JobShardingStrategy, TypedSPI

public final class AverageAllocationJobShardingStrategy
extends Object
implements JobShardingStrategy

Sharding strategy which for average by sharding item.

If the job server number and sharding count cannot be divided, the redundant sharding item that cannot be divided will be added to the server with small sequence number in turn. For example: 1. If there are 3 job servers and the total sharding count is 9, each job server is divided into: 1=[0,1,2], 2=[3,4,5], 3=[6,7,8]; 2. If there are 3 job servers and the total sharding count is 8, each job server is divided into: 1=[0,1,6], 2=[2,3,7], 3=[4,5]; 3. If there are 3 job servers and the total sharding count is 10, each job server is divided into: 1=[0,1,2,9], 2=[3,4,5], 3=[6,7,8].

构造器概要

构造器

构造器和说明
AverageAllocationJobShardingStrategy()

方法概要

限定符和类型	方法和说明
String	getType() Get type.
Map<JobInstance,List<Integer>>	sharding(List<JobInstance> jobInstances, String jobName, int shardingTotalCount) Sharding job.

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

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

构造器详细资料

AverageAllocationJobShardingStrategy

public AverageAllocationJobShardingStrategy()

方法详细资料

sharding

public Map<JobInstance,List<Integer>> sharding(List<JobInstance> jobInstances,
                                               String jobName,
                                               int shardingTotalCount)

从接口复制的说明: JobShardingStrategy

Sharding job.

指定者:

sharding 在接口中 JobShardingStrategy

参数:

jobInstances - all job instances which participate in sharding

jobName - job name

shardingTotalCount - sharding total count

返回:

sharding result

getType

public String getType()

从接口复制的说明: TypedSPI

Get type.

指定者:

getType 在接口中 TypedSPI

返回:

type