public class OperationRouting extends AbstractComponent
Modifier and Type | Field | Description |
---|---|---|
static Setting<java.lang.Boolean> |
USE_ADAPTIVE_REPLICA_SELECTION_SETTING |
deprecationLogger, logger, settings
Constructor | Description |
---|---|
OperationRouting(Settings settings,
ClusterSettings clusterSettings) |
Modifier and Type | Method | Description |
---|---|---|
static int |
generateShardId(IndexMetaData indexMetaData,
java.lang.String id,
java.lang.String routing) |
|
ShardIterator |
getShards(ClusterState clusterState,
java.lang.String index,
int shardId,
java.lang.String preference) |
|
ShardIterator |
getShards(ClusterState clusterState,
java.lang.String index,
java.lang.String id,
java.lang.String routing,
java.lang.String preference) |
|
protected IndexMetaData |
indexMetaData(ClusterState clusterState,
java.lang.String index) |
|
protected IndexRoutingTable |
indexRoutingTable(ClusterState clusterState,
java.lang.String index) |
|
ShardIterator |
indexShards(ClusterState clusterState,
java.lang.String index,
java.lang.String id,
java.lang.String routing) |
|
GroupShardsIterator<ShardIterator> |
searchShards(ClusterState clusterState,
java.lang.String[] concreteIndices,
java.util.Map<java.lang.String,java.util.Set<java.lang.String>> routing,
java.lang.String preference) |
|
GroupShardsIterator<ShardIterator> |
searchShards(ClusterState clusterState,
java.lang.String[] concreteIndices,
java.util.Map<java.lang.String,java.util.Set<java.lang.String>> routing,
java.lang.String preference,
ResponseCollectorService collectorService,
java.util.Map<java.lang.String,java.lang.Long> nodeCounts) |
|
ShardId |
shardId(ClusterState clusterState,
java.lang.String index,
java.lang.String id,
java.lang.String routing) |
|
protected IndexShardRoutingTable |
shards(ClusterState clusterState,
java.lang.String index,
java.lang.String id,
java.lang.String routing) |
logDeprecatedSetting, logRemovedSetting, nodeName
public static final Setting<java.lang.Boolean> USE_ADAPTIVE_REPLICA_SELECTION_SETTING
public OperationRouting(Settings settings, ClusterSettings clusterSettings)
public ShardIterator indexShards(ClusterState clusterState, java.lang.String index, java.lang.String id, @Nullable java.lang.String routing)
public ShardIterator getShards(ClusterState clusterState, java.lang.String index, java.lang.String id, @Nullable java.lang.String routing, @Nullable java.lang.String preference)
public ShardIterator getShards(ClusterState clusterState, java.lang.String index, int shardId, @Nullable java.lang.String preference)
public GroupShardsIterator<ShardIterator> searchShards(ClusterState clusterState, java.lang.String[] concreteIndices, @Nullable java.util.Map<java.lang.String,java.util.Set<java.lang.String>> routing, @Nullable java.lang.String preference)
public GroupShardsIterator<ShardIterator> searchShards(ClusterState clusterState, java.lang.String[] concreteIndices, @Nullable java.util.Map<java.lang.String,java.util.Set<java.lang.String>> routing, @Nullable java.lang.String preference, @Nullable ResponseCollectorService collectorService, @Nullable java.util.Map<java.lang.String,java.lang.Long> nodeCounts)
protected IndexRoutingTable indexRoutingTable(ClusterState clusterState, java.lang.String index)
protected IndexMetaData indexMetaData(ClusterState clusterState, java.lang.String index)
protected IndexShardRoutingTable shards(ClusterState clusterState, java.lang.String index, java.lang.String id, java.lang.String routing)
public ShardId shardId(ClusterState clusterState, java.lang.String index, java.lang.String id, @Nullable java.lang.String routing)
public static int generateShardId(IndexMetaData indexMetaData, @Nullable java.lang.String id, @Nullable java.lang.String routing)