org.apache.hadoop.contrib.index.example

类 RoundRobinDistributionPolicy

java.lang.Object

org.apache.hadoop.contrib.index.example.RoundRobinDistributionPolicy

所有已实现的接口:

IDistributionPolicy

public class RoundRobinDistributionPolicy
extends Object
implements IDistributionPolicy

Choose a shard for each insert in a round-robin fashion. Choose all the shards for each delete because we don't know where it is stored.

构造器概要

构造器

构造器和说明
RoundRobinDistributionPolicy()

方法概要

方法

限定符和类型	方法和说明
int	chooseShardForDelete(DocumentID key) Choose a shard or all shards to send a delete request.
int	chooseShardForInsert(DocumentID key) Choose a shard to send an insert request.
void	init(Shard[] shards) Initialization.

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

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

构造器详细资料

RoundRobinDistributionPolicy

public RoundRobinDistributionPolicy()

方法详细资料

init

public void init(Shard[] shards)

从接口复制的说明: IDistributionPolicy

Initialization. It must be called before any chooseShard() is called.

指定者:

init 在接口中 IDistributionPolicy

chooseShardForInsert

public int chooseShardForInsert(DocumentID key)

从接口复制的说明: IDistributionPolicy

Choose a shard to send an insert request.

指定者:

chooseShardForInsert 在接口中 IDistributionPolicy

返回:

the index of the chosen shard

chooseShardForDelete

public int chooseShardForDelete(DocumentID key)

从接口复制的说明: IDistributionPolicy

Choose a shard or all shards to send a delete request. E.g. a round-robin distribution policy would send a delete request to all the shards. -1 represents all the shards.

指定者:

chooseShardForDelete 在接口中 IDistributionPolicy

返回:

the index of the chosen shard, -1 if all the shards are chosen