org.apache.hadoop.contrib.index.mapred

接口 IDistributionPolicy

所有已知实现类:

HashingDistributionPolicy, RoundRobinDistributionPolicy

public interface IDistributionPolicy

A distribution policy decides, given a document with a document id, which one shard the request should be sent to if the request is an insert, and which shard(s) the request should be sent to if the request is a delete.

方法概要

方法

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

方法详细资料

init

void init(Shard[] shards)

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

参数:

shards -

chooseShardForInsert

int chooseShardForInsert(DocumentID key)

Choose a shard to send an insert request.

参数:

key -

返回:

the index of the chosen shard

chooseShardForDelete

int chooseShardForDelete(DocumentID key)

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.

参数:

key -

返回:

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