org.apache.hadoop.contrib.index.example

类 HashingDistributionPolicy

java.lang.Object

org.apache.hadoop.contrib.index.example.HashingDistributionPolicy

所有已实现的接口:

IDistributionPolicy

public class HashingDistributionPolicy
extends Object
implements IDistributionPolicy

Choose a shard for each insert or delete based on document id hashing. Do NOT use this distribution policy when the number of shards changes.

构造器概要

构造器

构造器和说明
HashingDistributionPolicy()

方法概要

方法

限定符和类型	方法和说明
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

构造器详细资料

HashingDistributionPolicy

public HashingDistributionPolicy()

方法详细资料

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