org.elasticsearch.indices

Class IndicesService

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.common.component.AbstractLifecycleComponent

org.elasticsearch.indices.IndicesService

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.lang.Iterable<IndexService>, LifecycleComponent, Releasable, IndexService.ShardStoreDeleter, IndicesClusterStateService.AllocatedIndices<IndexShard,IndexService>

public class IndicesService
extends AbstractLifecycleComponent
implements IndicesClusterStateService.AllocatedIndices<IndexShard,IndexService>, IndexService.ShardStoreDeleter

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	IndicesService.ShardDeletionCheckResult result type returned by signaling different reasons why a shard can / cannot be deleted

Nested classes/interfaces inherited from interface org.elasticsearch.indices.cluster.IndicesClusterStateService.AllocatedIndices

IndicesClusterStateService.AllocatedIndices.IndexRemovalReason

Field Summary

Fields

Modifier and Type	Field and Description
static Setting<TimeValue>	INDICES_CACHE_CLEAN_INTERVAL_SETTING
static java.lang.String	INDICES_SHARDS_CLOSED_TIMEOUT

Fields inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent

lifecycle

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

deprecationLogger, logger, settings

Constructor Summary

Constructors

Constructor and Description

IndicesService(Settings settings, PluginsService pluginsService, NodeEnvironment nodeEnv, NamedXContentRegistry xContentRegistry, ClusterSettings clusterSettings, AnalysisRegistry analysisRegistry, IndexNameExpressionResolver indexNameExpressionResolver, MapperRegistry mapperRegistry, NamedWriteableRegistry namedWriteableRegistry, ThreadPool threadPool, IndexScopedSettings indexScopedSettings, CircuitBreakerService circuitBreakerService, BigArrays bigArrays, ScriptService scriptService, ClusterService clusterService, Client client, MetaStateService metaStateService)

Method Summary

Modifier and Type	Method and Description
void	addPendingDelete(Index index, IndexSettings settings) Adds a pending delete for the given index.
void	addPendingDelete(ShardId shardId, IndexSettings settings) Adds a pending delete for the given index shard.
AliasFilter	buildAliasFilter(ClusterState state, java.lang.String index, java.lang.String... expressions)
boolean	canCache(ShardSearchRequest request, SearchContext context) Can the shard request be cached at all?
boolean	canDeleteIndexContents(Index index, IndexSettings indexSettings) This method returns true if the current node is allowed to delete the given index.
IndicesService.ShardDeletionCheckResult	canDeleteShardContent(ShardId shardId, IndexSettings indexSettings) Returns ShardDeletionCheckResult signaling whether the shards content for the given shard can be deleted.
void	clearRequestCache(IndexShard shard)
IndexService	createIndex(IndexMetaData indexMetaData, java.util.List<IndexEventListener> builtInListeners) Creates a new IndexService for the given metadata.
MapperService	createIndexMapperService(IndexMetaData indexMetaData) creates a new mapper service for the given index, in order to do administrative work like mapping updates.
IndexShard	createShard(ShardRouting shardRouting, RecoveryState recoveryState, PeerRecoveryTargetService recoveryTargetService, PeerRecoveryTargetService.RecoveryListener recoveryListener, RepositoriesService repositoriesService, java.util.function.Consumer<IndexShard.ShardFailure> onShardFailure) Creates shard for the specified shard routing and starts recovery,
void	deleteShardStore(java.lang.String reason, ShardId shardId, ClusterState clusterState) This method deletes the shard contents on disk for the given shard ID.
void	deleteShardStore(java.lang.String reason, ShardLock lock, IndexSettings indexSettings) Deletes the shard with an already acquired shard lock.
void	deleteUnassignedIndex(java.lang.String reason, IndexMetaData metaData, ClusterState clusterState) Deletes an index that is not assigned to this node.
protected void	doClose()
protected void	doStart()
protected void	doStop()
AnalysisRegistry	getAnalysis()
CircuitBreakerService	getCircuitBreakerService()
FieldStats<?>	getFieldStats(IndexShard shard, Engine.Searcher searcher, java.lang.String field, boolean useCache) Fetch FieldStats for a field.
IndicesFieldDataCache	getIndicesFieldDataCache()
IndicesQueryCache	getIndicesQueryCache()
ByteSizeValue	getTotalIndexingBufferBytes()
boolean	hasIndex(Index index)
boolean	hasUncompletedPendingDeletes() Checks if all pending deletes have completed.
IndexService	indexService(Index index) Returns an IndexService for the specified index if exists otherwise returns null.
IndexService	indexServiceSafe(Index index) Returns an IndexService for the specified index if exists otherwise a IndexNotFoundException is thrown.
java.util.Iterator<IndexService>	iterator()
void	loadIntoContext(ShardSearchRequest request, SearchContext context, QueryPhase queryPhase) Loads the cache result, computing it if needed by executing the query phase and otherwise deserializing the cached value into the context's query result.
void	processPendingDeletes(Index index, IndexSettings indexSettings, TimeValue timeout) Processes all pending deletes for the given index.
void	removeIndex(Index index, IndicesClusterStateService.AllocatedIndices.IndexRemovalReason reason, java.lang.String extraInfo) Removes the given index from this service and releases all associated resources.
NodeIndicesStats	stats(boolean includePrevious) Returns the node stats indices stats.
NodeIndicesStats	stats(boolean includePrevious, CommonStatsFlags flags)
IndexMetaData	verifyIndexIsDeleted(Index index, ClusterState clusterState) Verify that the contents on disk for the given index is deleted; if not, delete the contents.
void	verifyIndexMetadata(IndexMetaData metaData, IndexMetaData metaDataUpdate) This method verifies that the given metaData holds sane values to create an IndexService.

Methods inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent

addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

logDeprecatedSetting, logRemovedSetting, nodeName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.elasticsearch.indices.cluster.IndicesClusterStateService.AllocatedIndices

getShardOrNull

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

INDICES_SHARDS_CLOSED_TIMEOUT

public static final java.lang.String INDICES_SHARDS_CLOSED_TIMEOUT

See Also:

Constant Field Values

INDICES_CACHE_CLEAN_INTERVAL_SETTING

public static final Setting<TimeValue> INDICES_CACHE_CLEAN_INTERVAL_SETTING

Constructor Detail

IndicesService

public IndicesService(Settings settings,
                      PluginsService pluginsService,
                      NodeEnvironment nodeEnv,
                      NamedXContentRegistry xContentRegistry,
                      ClusterSettings clusterSettings,
                      AnalysisRegistry analysisRegistry,
                      IndexNameExpressionResolver indexNameExpressionResolver,
                      MapperRegistry mapperRegistry,
                      NamedWriteableRegistry namedWriteableRegistry,
                      ThreadPool threadPool,
                      IndexScopedSettings indexScopedSettings,
                      CircuitBreakerService circuitBreakerService,
                      BigArrays bigArrays,
                      ScriptService scriptService,
                      ClusterService clusterService,
                      Client client,
                      MetaStateService metaStateService)

Method Detail

doStart

protected void doStart()

Specified by:

doStart in class AbstractLifecycleComponent

doStop

protected void doStop()

Specified by:

doStop in class AbstractLifecycleComponent

doClose

protected void doClose()

Specified by:

doClose in class AbstractLifecycleComponent

stats

public NodeIndicesStats stats(boolean includePrevious)

Returns the node stats indices stats. The includePrevious flag controls if old shards stats will be aggregated as well (only for relevant stats, such as refresh and indexing, not for docs/store).

stats

public NodeIndicesStats stats(boolean includePrevious,
                              CommonStatsFlags flags)

iterator

public java.util.Iterator<IndexService> iterator()

Specified by:

iterator in interface java.lang.Iterable<IndexService>

hasIndex

public boolean hasIndex(Index index)

indexService

@Nullable
public IndexService indexService(Index index)

Returns an IndexService for the specified index if exists otherwise returns null.

Specified by:

indexService in interface IndicesClusterStateService.AllocatedIndices<IndexShard,IndexService>

indexServiceSafe

public IndexService indexServiceSafe(Index index)

Returns an IndexService for the specified index if exists otherwise a IndexNotFoundException is thrown.

createIndex

public IndexService createIndex(IndexMetaData indexMetaData,
                                java.util.List<IndexEventListener> builtInListeners)
                         throws java.io.IOException

Creates a new IndexService for the given metadata.

Specified by:

createIndex in interface IndicesClusterStateService.AllocatedIndices<IndexShard,IndexService>

Parameters:

indexMetaData - the index metadata to create the index for

builtInListeners - a list of built-in lifecycle IndexEventListener that should should be used along side with the per-index listeners

Throws:

ResourceAlreadyExistsException - if the index already exists.

java.io.IOException

createIndexMapperService

public MapperService createIndexMapperService(IndexMetaData indexMetaData)
                                       throws java.io.IOException

creates a new mapper service for the given index, in order to do administrative work like mapping updates. This *should not* be used for document parsing. Doing so will result in an exception. Note: the returned MapperService should be closed when unneeded.

Throws:

java.io.IOException

verifyIndexMetadata

public void verifyIndexMetadata(IndexMetaData metaData,
                                IndexMetaData metaDataUpdate)
                         throws java.io.IOException

This method verifies that the given metaData holds sane values to create an IndexService. This method tries to update the meta data of the created IndexService if the given metaDataUpdate is different from the given metaData. This method will throw an exception if the creation or the update fails. The created IndexService will not be registered and will be closed immediately.

Throws:

java.io.IOException

createShard

public IndexShard createShard(ShardRouting shardRouting,
                              RecoveryState recoveryState,
                              PeerRecoveryTargetService recoveryTargetService,
                              PeerRecoveryTargetService.RecoveryListener recoveryListener,
                              RepositoriesService repositoriesService,
                              java.util.function.Consumer<IndexShard.ShardFailure> onShardFailure)
                       throws java.io.IOException

Description copied from interface: IndicesClusterStateService.AllocatedIndices

Creates shard for the specified shard routing and starts recovery,

Specified by:

createShard in interface IndicesClusterStateService.AllocatedIndices<IndexShard,IndexService>

Throws:

java.io.IOException

removeIndex

public void removeIndex(Index index,
                        IndicesClusterStateService.AllocatedIndices.IndexRemovalReason reason,
                        java.lang.String extraInfo)

Description copied from interface: IndicesClusterStateService.AllocatedIndices

Removes the given index from this service and releases all associated resources. Persistent parts of the index like the shards files, state and transaction logs are kept around in the case of a disaster recovery.

Specified by:

removeIndex in interface IndicesClusterStateService.AllocatedIndices<IndexShard,IndexService>

Parameters:

index - the index to remove

reason - the reason to remove the index

extraInfo - extra information that will be used for logging and reporting

getIndicesFieldDataCache

public IndicesFieldDataCache getIndicesFieldDataCache()

getCircuitBreakerService

public CircuitBreakerService getCircuitBreakerService()

getIndicesQueryCache

public IndicesQueryCache getIndicesQueryCache()

deleteUnassignedIndex

public void deleteUnassignedIndex(java.lang.String reason,
                                  IndexMetaData metaData,
                                  ClusterState clusterState)

Deletes an index that is not assigned to this node. This method cleans up all disk folders relating to the index but does not deal with in-memory structures. For those call IndicesClusterStateService.AllocatedIndices.removeIndex(Index, IndexRemovalReason, String)

Specified by:

deleteUnassignedIndex in interface IndicesClusterStateService.AllocatedIndices<IndexShard,IndexService>

deleteShardStore

public void deleteShardStore(java.lang.String reason,
                             ShardLock lock,
                             IndexSettings indexSettings)
                      throws java.io.IOException

Deletes the shard with an already acquired shard lock.

Specified by:

deleteShardStore in interface IndexService.ShardStoreDeleter

Parameters:

reason - the reason for the shard deletion

lock - the lock of the shard to delete

indexSettings - the shards index settings.

Throws:

java.io.IOException - if an IOException occurs

deleteShardStore

public void deleteShardStore(java.lang.String reason,
                             ShardId shardId,
                             ClusterState clusterState)
                      throws java.io.IOException,
                             ShardLockObtainFailedException

This method deletes the shard contents on disk for the given shard ID. This method will fail if the shard deleting is prevented by canDeleteShardContent(ShardId, IndexSettings) of if the shards lock can not be acquired. On data nodes, if the deleted shard is the last shard folder in its index, the method will attempt to remove the index folder as well.

Parameters:

reason - the reason for the shard deletion

shardId - the shards ID to delete

clusterState - . This is required to access the indexes settings etc.

Throws:

java.io.IOException - if an IOException occurs

ShardLockObtainFailedException

canDeleteIndexContents

public boolean canDeleteIndexContents(Index index,
                                      IndexSettings indexSettings)

This method returns true if the current node is allowed to delete the given index. This is the case if the index is deleted in the metadata or there is no allocation on the local node and the index isn't on a shared file system.

Parameters:

index - Index to check whether deletion is allowed

indexSettings - IndexSettings for the given index

Returns:

true if the index can be deleted on this node

verifyIndexIsDeleted

@Nullable
public IndexMetaData verifyIndexIsDeleted(Index index,
                                                    ClusterState clusterState)

Verify that the contents on disk for the given index is deleted; if not, delete the contents. This method assumes that an index is already deleted in the cluster state and/or explicitly through index tombstones.

Specified by:

verifyIndexIsDeleted in interface IndicesClusterStateService.AllocatedIndices<IndexShard,IndexService>

Parameters:

index - Index to make sure its deleted from disk

clusterState - ClusterState to ensure the index is not part of it

Returns:

IndexMetaData for the index loaded from disk

canDeleteShardContent

public IndicesService.ShardDeletionCheckResult canDeleteShardContent(ShardId shardId,
                                                                     IndexSettings indexSettings)

Returns ShardDeletionCheckResult signaling whether the shards content for the given shard can be deleted.

Parameters:

shardId - the shard to delete.

indexSettings - the shards's relevant IndexSettings. This is required to access the indexes settings etc.

addPendingDelete

public void addPendingDelete(ShardId shardId,
                             IndexSettings settings)

Adds a pending delete for the given index shard.

Specified by:

addPendingDelete in interface IndexService.ShardStoreDeleter

addPendingDelete

public void addPendingDelete(Index index,
                             IndexSettings settings)

Adds a pending delete for the given index.

processPendingDeletes

public void processPendingDeletes(Index index,
                                  IndexSettings indexSettings,
                                  TimeValue timeout)
                           throws java.io.IOException,
                                  java.lang.InterruptedException,
                                  ShardLockObtainFailedException

Processes all pending deletes for the given index. This method will acquire all locks for the given index and will process all pending deletes for this index. Pending deletes might occur if the OS doesn't allow deletion of files because they are used by a different process ie. on Windows where files might still be open by a virus scanner. On a shared filesystem a replica might not have been closed when the primary is deleted causing problems on delete calls so we schedule there deletes later.

Specified by:

processPendingDeletes in interface IndicesClusterStateService.AllocatedIndices<IndexShard,IndexService>

Parameters:

index - the index to process the pending deletes for

timeout - the timeout used for processing pending deletes

Throws:

java.io.IOException

java.lang.InterruptedException

ShardLockObtainFailedException

hasUncompletedPendingDeletes

public boolean hasUncompletedPendingDeletes()

Checks if all pending deletes have completed. Used by tests to ensure we don't check directory contents while deletion still ongoing. The reason is that, on Windows, browsing the directory contents can interfere with the deletion process and delay it unnecessarily.

getAnalysis

public AnalysisRegistry getAnalysis()

canCache

public boolean canCache(ShardSearchRequest request,
                        SearchContext context)

Can the shard request be cached at all?

clearRequestCache

public void clearRequestCache(IndexShard shard)

loadIntoContext

public void loadIntoContext(ShardSearchRequest request,
                            SearchContext context,
                            QueryPhase queryPhase)
                     throws java.lang.Exception

Loads the cache result, computing it if needed by executing the query phase and otherwise deserializing the cached value into the context's query result. The combination of load + compute allows to have a single load operation that will cause other requests with the same key to wait till its loaded an reuse the same cache.

Throws:

java.lang.Exception

getFieldStats

public FieldStats<?> getFieldStats(IndexShard shard,
                                   Engine.Searcher searcher,
                                   java.lang.String field,
                                   boolean useCache)
                            throws java.lang.Exception

Fetch FieldStats for a field. These stats are cached until the shard changes.

Parameters:

shard - the shard to use with the cache key

searcher - searcher to use to lookup the field stats

field - the actual field

useCache - should this request use the cache?

Throws:

java.lang.Exception

getTotalIndexingBufferBytes

public ByteSizeValue getTotalIndexingBufferBytes()

buildAliasFilter

public AliasFilter buildAliasFilter(ClusterState state,
                                    java.lang.String index,
                                    java.lang.String... expressions)