Constructor and Description |
---|
CommonStats(IndexShard indexShard,
CommonStatsFlags flags) |
ShardStats(IndexShard indexShard,
ShardRouting shardRouting,
CommonStatsFlags flags) |
Modifier and Type | Method and Description |
---|---|
UpdateHelper.Result |
UpdateHelper.prepare(UpdateRequest request,
IndexShard indexShard)
Prepares an update request by converting it into an index or delete request or an update response (no action).
|
Modifier and Type | Method and Description |
---|---|
IndexShard |
IndexService.createShard(int sShardId,
boolean primary) |
IndexShard |
IndexService.shard(int shardId)
Return the shard with the provided id, or null if there is no such shard.
|
IndexShard |
IndexService.shardSafe(int shardId)
Return the shard with the provided id, or throw an exception if it doesn't exist.
|
Modifier and Type | Method and Description |
---|---|
Iterator<IndexShard> |
IndexService.iterator() |
Constructor and Description |
---|
IndexShardGatewayService(ShardId shardId,
Settings indexSettings,
ThreadPool threadPool,
IndexShard indexShard,
IndexShardGateway shardGateway,
IndexShardSnapshotAndRestoreService snapshotService,
ClusterService clusterService) |
Constructor and Description |
---|
LocalIndexShardGateway(ShardId shardId,
Settings indexSettings,
ThreadPool threadPool,
MappingUpdatedAction mappingUpdatedAction,
IndexService indexService,
IndexShard indexShard) |
Constructor and Description |
---|
NoneIndexShardGateway(ShardId shardId,
Settings indexSettings,
IndexShard indexShard) |
Modifier and Type | Method and Description |
---|---|
ShardGetService |
ShardGetService.setIndexShard(IndexShard indexShard) |
Modifier and Type | Class and Description |
---|---|
class |
ShadowIndexShard
ShadowIndexShard extends
IndexShard to add file synchronization
from the primary when a flush happens. |
Modifier and Type | Method and Description |
---|---|
IndexShard |
IndexShard.postRecovery(String reason) |
IndexShard |
IndexShard.relocated(String reason) |
IndexShard |
ShadowIndexShard.routingEntry(ShardRouting newRouting)
In addition to the regular accounting done in
routingEntry(org.elasticsearch.cluster.routing.ShardRouting) ,
if this shadow replica needs to be promoted to a primary, the shard is
failed in order to allow a new primary to be re-allocated. |
IndexShard |
IndexShard.routingEntry(ShardRouting newRouting) |
Constructor and Description |
---|
IndexShardSnapshotAndRestoreService(ShardId shardId,
Settings indexSettings,
IndexShard indexShard,
RepositoriesService repositoriesService,
RestoreService restoreService) |
Modifier and Type | Method and Description |
---|---|
ShardTermVectorService |
ShardTermVectorService.setIndexShard(IndexShard indexShard) |
Constructor and Description |
---|
TranslogService(ShardId shardId,
Settings indexSettings,
IndexSettingsService indexSettingsService,
ThreadPool threadPool,
IndexShard indexShard,
Translog translog) |
Modifier and Type | Method and Description |
---|---|
void |
InternalIndicesLifecycle.afterIndexShardClosed(ShardId shardId,
IndexShard indexShard,
Settings indexSettings) |
void |
IndicesLifecycle.Listener.afterIndexShardClosed(ShardId shardId,
IndexShard indexShard,
Settings indexSettings)
Called after the index shard has been closed.
|
void |
InternalIndicesLifecycle.afterIndexShardCreated(IndexShard indexShard) |
void |
IndicesLifecycle.Listener.afterIndexShardCreated(IndexShard indexShard)
Called after the index shard has been created.
|
void |
InternalIndicesLifecycle.afterIndexShardPostRecovery(IndexShard indexShard) |
void |
IndicesLifecycle.Listener.afterIndexShardPostRecovery(IndexShard indexShard) |
void |
InternalIndicesLifecycle.afterIndexShardStarted(IndexShard indexShard) |
void |
IndicesLifecycle.Listener.afterIndexShardStarted(IndexShard indexShard)
Called after the index shard has been started.
|
void |
InternalIndicesLifecycle.beforeIndexShardClosed(ShardId shardId,
IndexShard indexShard,
Settings indexSettings) |
void |
IndicesLifecycle.Listener.beforeIndexShardClosed(ShardId shardId,
IndexShard indexShard,
Settings indexSettings)
Called before the index shard gets closed.
|
void |
IndicesLifecycle.Listener.indexShardStateChanged(IndexShard indexShard,
IndexShardState previousState,
IndexShardState currentState,
String reason)
Called after a shard's
IndexShardState changes. |
void |
InternalIndicesLifecycle.indexShardStateChanged(IndexShard indexShard,
IndexShardState previousState,
String reason) |
void |
InternalIndicesLifecycle.shardRoutingChanged(IndexShard indexShard,
ShardRouting oldRouting,
ShardRouting newRouting) |
void |
IndicesLifecycle.Listener.shardRoutingChanged(IndexShard indexShard,
ShardRouting oldRouting,
ShardRouting newRouting)
Called when the shard routing has changed state.
|
abstract IndicesWarmer.TerminationHandle |
IndicesWarmer.Listener.warmNewReaders(IndexShard indexShard,
IndexMetaData indexMetaData,
IndicesWarmer.WarmerContext context,
ThreadPool threadPool)
Queue tasks to warm-up the given segments and return handles that allow to wait for termination of the execution of those tasks.
|
abstract IndicesWarmer.TerminationHandle |
IndicesWarmer.Listener.warmTopReader(IndexShard indexShard,
IndexMetaData indexMetaData,
IndicesWarmer.WarmerContext context,
ThreadPool threadPool) |
Modifier and Type | Field and Description |
---|---|
IndexShard |
IndicesQueryCache.Key.shard |
Modifier and Type | Method and Description |
---|---|
void |
IndicesQueryCache.clear(IndexShard shard) |
Modifier and Type | Method and Description |
---|---|
IndexShard |
RecoveryStatus.indexShard() |
Modifier and Type | Method and Description |
---|---|
RecoveriesCollection.StatusRef |
RecoveriesCollection.findRecoveryByShard(IndexShard indexShard)
Try to find an ongoing recovery for a given shard.
|
RecoveryState |
RecoveryTarget.recoveryState(IndexShard indexShard) |
long |
RecoveriesCollection.startRecovery(IndexShard indexShard,
DiscoveryNode sourceNode,
RecoveryTarget.RecoveryListener listener,
TimeValue activityTimeout)
Starts are new recovery for the given shard, source node and state
|
void |
RecoveryTarget.startRecovery(IndexShard indexShard,
RecoveryState.Type recoveryType,
DiscoveryNode sourceNode,
RecoveryTarget.RecoveryListener listener) |
Constructor and Description |
---|
RecoverySourceHandler(IndexShard shard,
StartRecoveryRequest request,
RecoverySettings recoverySettings,
TransportService transportService,
ClusterService clusterService,
IndicesService indicesService,
MappingUpdatedAction mappingUpdatedAction,
ESLogger logger) |
RecoveryStatus(IndexShard indexShard,
DiscoveryNode sourceNode,
RecoveryTarget.RecoveryListener listener) |
SharedFSRecoverySourceHandler(IndexShard shard,
StartRecoveryRequest request,
RecoverySettings recoverySettings,
TransportService transportService,
ClusterService clusterService,
IndicesService indicesService,
MappingUpdatedAction mappingUpdatedAction,
ESLogger logger) |
Modifier and Type | Method and Description |
---|---|
IndexShard |
PercolateContext.indexShard() |
Constructor and Description |
---|
PercolateContext(PercolateShardRequest request,
SearchShardTarget searchShardTarget,
IndexShard indexShard,
IndexService indexService,
CacheRecycler cacheRecycler,
PageCacheRecycler pageCacheRecycler,
BigArrays bigArrays,
ScriptService scriptService,
org.apache.lucene.search.Filter aliasFilter) |
Modifier and Type | Method and Description |
---|---|
abstract IndexShard |
SearchContext.indexShard() |
IndexShard |
FilteredSearchContext.indexShard() |
IndexShard |
DefaultSearchContext.indexShard() |
Constructor and Description |
---|
DefaultSearchContext(long id,
ShardSearchRequest request,
SearchShardTarget shardTarget,
Engine.Searcher engineSearcher,
IndexService indexService,
IndexShard indexShard,
ScriptService scriptService,
CacheRecycler cacheRecycler,
PageCacheRecycler pageCacheRecycler,
BigArrays bigArrays,
org.apache.lucene.util.Counter timeEstimateCounter) |
Copyright © 2009–2015. All rights reserved.