org.apache.shardingsphere.elasticjob.lite.internal.sharding

Class ShardingService

java.lang.Object

org.apache.shardingsphere.elasticjob.lite.internal.sharding.ShardingService

public final class ShardingService
extends Object

Sharding service.

Constructor Summary

Constructors

Constructor and Description
ShardingService(CoordinatorRegistryCenter regCenter, String jobName)

Method Summary

Modifier and Type	Method and Description
List<Integer>	getCrashedShardingItems(String jobInstanceId) Get crashed sharding items.
List<Integer>	getLocalShardingItems() Get sharding items from localhost job server.
List<Integer>	getShardingItems(String jobInstanceId) Get sharding items.
boolean	hasShardingInfoInOfflineServers() Query has sharding info in offline servers or not.
boolean	isNeedSharding() Judge is need resharding or not.
void	setReshardingFlag() Set resharding flag.
void	shardingIfNecessary() Sharding if necessary.

Methods inherited from class java.lang.Object

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

Constructor Detail

ShardingService

public ShardingService(CoordinatorRegistryCenter regCenter,
                       String jobName)

Method Detail

setReshardingFlag

public void setReshardingFlag()

Set resharding flag.

isNeedSharding

public boolean isNeedSharding()

Judge is need resharding or not.

Returns:

is need resharding or not

shardingIfNecessary

public void shardingIfNecessary()

Sharding if necessary.

Sharding if current job server is leader server; Do not sharding if no available job server.

getShardingItems

public List<Integer> getShardingItems(String jobInstanceId)

Get sharding items.

Parameters:

jobInstanceId - job instance ID

Returns:

sharding items

getCrashedShardingItems

public List<Integer> getCrashedShardingItems(String jobInstanceId)

Get crashed sharding items.

Parameters:

jobInstanceId - crashed job instance ID

Returns:

crashed sharding items

getLocalShardingItems

public List<Integer> getLocalShardingItems()

Get sharding items from localhost job server.

Returns:

sharding items from localhost job server

hasShardingInfoInOfflineServers

public boolean hasShardingInfoInOfflineServers()

Query has sharding info in offline servers or not.

Returns:

has sharding info in offline servers or not