public class PlainOperationRouting extends AbstractComponent implements OperationRouting
componentSettings, logger, settings
Constructor and Description |
---|
PlainOperationRouting(Settings indexSettings,
HashFunction hashFunction,
AwarenessAllocationDecider awarenessAllocationDecider) |
nodeName
@Inject public PlainOperationRouting(Settings indexSettings, HashFunction hashFunction, AwarenessAllocationDecider awarenessAllocationDecider)
public ShardIterator indexShards(ClusterState clusterState, String index, String type, String id, @Nullable String routing) throws IndexMissingException, IndexShardMissingException
indexShards
in interface OperationRouting
IndexMissingException
IndexShardMissingException
public ShardIterator deleteShards(ClusterState clusterState, String index, String type, String id, @Nullable String routing) throws IndexMissingException, IndexShardMissingException
deleteShards
in interface OperationRouting
IndexMissingException
IndexShardMissingException
public ShardIterator getShards(ClusterState clusterState, String index, String type, String id, @Nullable String routing, @Nullable String preference) throws IndexMissingException, IndexShardMissingException
getShards
in interface OperationRouting
IndexMissingException
IndexShardMissingException
public ShardIterator getShards(ClusterState clusterState, String index, int shardId, @Nullable String preference) throws IndexMissingException, IndexShardMissingException
getShards
in interface OperationRouting
IndexMissingException
IndexShardMissingException
public GroupShardsIterator broadcastDeleteShards(ClusterState clusterState, String index) throws IndexMissingException
broadcastDeleteShards
in interface OperationRouting
IndexMissingException
public GroupShardsIterator deleteByQueryShards(ClusterState clusterState, String index, @Nullable Set<String> routing) throws IndexMissingException
deleteByQueryShards
in interface OperationRouting
IndexMissingException
public int searchShardsCount(ClusterState clusterState, String[] indices, String[] concreteIndices, @Nullable Map<String,Set<String>> routing, @Nullable String preference) throws IndexMissingException
searchShardsCount
in interface OperationRouting
IndexMissingException
public GroupShardsIterator searchShards(ClusterState clusterState, String[] indices, String[] concreteIndices, @Nullable Map<String,Set<String>> routing, @Nullable String preference) throws IndexMissingException
searchShards
in interface OperationRouting
IndexMissingException
public IndexMetaData indexMetaData(ClusterState clusterState, String index)
protected IndexRoutingTable indexRoutingTable(ClusterState clusterState, String index)
protected IndexShardRoutingTable shards(ClusterState clusterState, String index, String type, String id, String routing)
protected IndexShardRoutingTable shards(ClusterState clusterState, String index, int shardId)
protected int hash(String routing)
Copyright © 2009–2015. All rights reserved.