Modifier and Type | Method and Description |
---|---|
protected GroupShardsIterator |
TransportClearIndicesCacheAction.shards(ClusterState clusterState,
ClearIndicesCacheRequest request,
String[] concreteIndices)
The refresh request works against *all* shards.
|
Modifier and Type | Method and Description |
---|---|
protected GroupShardsIterator |
TransportFlushAction.shards(ClusterState clusterState,
FlushRequest request,
String[] concreteIndices)
The refresh request works against *all* shards.
|
Modifier and Type | Method and Description |
---|---|
protected GroupShardsIterator |
TransportOptimizeAction.shards(ClusterState clusterState,
OptimizeRequest request,
String[] concreteIndices)
The refresh request works against *all* shards.
|
Modifier and Type | Method and Description |
---|---|
protected GroupShardsIterator |
TransportRecoveryAction.shards(ClusterState state,
RecoveryRequest request,
String[] concreteIndices) |
Modifier and Type | Method and Description |
---|---|
protected GroupShardsIterator |
TransportRefreshAction.shards(ClusterState clusterState,
RefreshRequest request,
String[] concreteIndices)
The refresh request works against *all* shards.
|
Modifier and Type | Method and Description |
---|---|
protected GroupShardsIterator |
TransportIndicesSegmentsAction.shards(ClusterState clusterState,
IndicesSegmentsRequest request,
String[] concreteIndices)
Segments goes across *all* active shards.
|
Modifier and Type | Method and Description |
---|---|
protected GroupShardsIterator |
TransportIndicesStatsAction.shards(ClusterState clusterState,
IndicesStatsRequest request,
String[] concreteIndices)
Status goes across *all* shards.
|
Modifier and Type | Method and Description |
---|---|
protected GroupShardsIterator |
TransportIndicesStatusAction.shards(ClusterState state,
IndicesStatusRequest request,
String[] concreteIndices)
Deprecated.
Status goes across *all* shards.
|
Modifier and Type | Method and Description |
---|---|
protected GroupShardsIterator |
TransportValidateQueryAction.shards(ClusterState clusterState,
ValidateQueryRequest request,
String[] concreteIndices) |
Modifier and Type | Method and Description |
---|---|
protected GroupShardsIterator |
TransportCountAction.shards(ClusterState clusterState,
CountRequest request,
String[] concreteIndices) |
Modifier and Type | Method and Description |
---|---|
protected GroupShardsIterator |
TransportIndexDeleteAction.shards(org.elasticsearch.action.delete.IndexDeleteRequest request) |
Modifier and Type | Method and Description |
---|---|
protected GroupShardsIterator |
TransportIndexDeleteByQueryAction.shards(org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest request) |
Modifier and Type | Method and Description |
---|---|
protected GroupShardsIterator |
TransportExistsAction.shards(ClusterState clusterState,
ExistsRequest request,
String[] concreteIndices) |
Modifier and Type | Method and Description |
---|---|
protected GroupShardsIterator |
TransportPercolateAction.shards(ClusterState clusterState,
PercolateRequest request,
String[] concreteIndices) |
Modifier and Type | Field and Description |
---|---|
protected GroupShardsIterator |
TransportSearchTypeAction.BaseAsyncAction.shardsIts |
Modifier and Type | Method and Description |
---|---|
protected GroupShardsIterator |
TransportSuggestAction.shards(ClusterState clusterState,
SuggestRequest request,
String[] concreteIndices) |
Modifier and Type | Method and Description |
---|---|
protected abstract GroupShardsIterator |
TransportBroadcastOperationAction.shards(ClusterState clusterState,
Request request,
String[] concreteIndices)
Determines the shards this operation will be executed on.
|
Modifier and Type | Method and Description |
---|---|
protected abstract GroupShardsIterator |
TransportIndexReplicationOperationAction.shards(Request request) |
Modifier and Type | Method and Description |
---|---|
GroupShardsIterator |
RoutingTable.activePrimaryShardsGrouped(String[] indices,
boolean includeEmpty)
All the *active* primary shards for the provided indices grouped (each group is a single element, consisting
of the primary shard).
|
GroupShardsIterator |
RoutingTable.allActiveShardsGrouped(String[] indices,
boolean includeEmpty) |
GroupShardsIterator |
RoutingTable.allActiveShardsGrouped(String[] indices,
boolean includeEmpty,
boolean includeRelocationTargets)
Return GroupShardsIterator where each active shard routing has it's own shard iterator.
|
GroupShardsIterator |
RoutingTable.allAssignedShardsGrouped(String[] indices,
boolean includeEmpty) |
GroupShardsIterator |
RoutingTable.allAssignedShardsGrouped(String[] indices,
boolean includeEmpty,
boolean includeRelocationTargets)
Return GroupShardsIterator where each assigned shard routing has it's own shard iterator.
|
GroupShardsIterator |
RoutingTable.allShardsGrouped(String... indices)
All the shards (primary + replicas) for the provided indices grouped (each group is a single element, consisting
of the shard).
|
GroupShardsIterator |
IndexRoutingTable.groupByAllIt()
A groups shards iterator where each groups is a single
ShardRouting and a group
is created for each shard routing. |
GroupShardsIterator |
IndexRoutingTable.groupByShardsIt()
A group shards iterator where each group (
ShardIterator
is an iterator across shard replication group. |
Modifier and Type | Method and Description |
---|---|
GroupShardsIterator |
OperationRouting.broadcastDeleteShards(ClusterState clusterState,
String index) |
GroupShardsIterator |
OperationRouting.deleteByQueryShards(ClusterState clusterState,
String index,
Set<String> routing) |
GroupShardsIterator |
OperationRouting.searchShards(ClusterState clusterState,
String[] indices,
String[] concreteIndices,
Map<String,Set<String>> routing,
String preference) |
Modifier and Type | Method and Description |
---|---|
GroupShardsIterator |
PlainOperationRouting.broadcastDeleteShards(ClusterState clusterState,
String index) |
GroupShardsIterator |
PlainOperationRouting.deleteByQueryShards(ClusterState clusterState,
String index,
Set<String> routing) |
GroupShardsIterator |
PlainOperationRouting.searchShards(ClusterState clusterState,
String[] indices,
String[] concreteIndices,
Map<String,Set<String>> routing,
String preference) |
Copyright © 2009–2015. All rights reserved.