Package org.elasticsearch.index

Class IndexService

java.lang.Object

org.elasticsearch.index.AbstractIndexComponent

org.elasticsearch.index.IndexService

All Implemented Interfaces:

java.lang.Iterable<IndexShard>, IndexComponent, IndicesClusterStateService.AllocatedIndex<IndexShard>

public class IndexService
extends AbstractIndexComponent
implements IndicesClusterStateService.AllocatedIndex<IndexShard>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	IndexService.ShardStoreDeleter

Field Summary

Fields

Modifier and Type	Field	Description
static Setting<TimeValue>	GLOBAL_CHECKPOINT_SYNC_INTERVAL_SETTING
static Setting<TimeValue>	RETENTION_LEASE_SYNC_INTERVAL_SETTING

Fields inherited from class org.elasticsearch.index.AbstractIndexComponent

deprecationLogger, logger

Constructor Summary

Constructors

Constructor

Description

IndexService(IndexSettings indexSettings, NodeEnvironment nodeEnv, NamedXContentRegistry xContentRegistry, SimilarityService similarityService, IndexService.ShardStoreDeleter shardStoreDeleter, AnalysisRegistry registry, EngineFactory engineFactory, CircuitBreakerService circuitBreakerService, BigArrays bigArrays, ThreadPool threadPool, ScriptService scriptService, Client client, QueryCache queryCache, IndexStore indexStore, IndexEventListener eventListener, IndexModule.IndexSearcherWrapperFactory wrapperFactory, MapperRegistry mapperRegistry, IndicesFieldDataCache indicesFieldDataCache, java.util.List<SearchOperationListener> searchOperationListeners, java.util.List<IndexingOperationListener> indexingOperationListeners, NamedWriteableRegistry namedWriteableRegistry)

Method Summary

Modifier and Type	Method	Description
IndexCache	cache()
boolean	clearCaches(boolean queryCache, boolean fieldDataCache, java.lang.String... fields)	Clears the caches for the given shard id if the shard is still allocated on this node
void	close(java.lang.String reason, boolean delete)
IndexShard	createShard(ShardRouting routing, java.util.function.Consumer<ShardId> globalCheckpointSyncer, RetentionLeaseSyncer retentionLeaseSyncer)
BigArrays	getBigArrays()	The BigArrays to use for this index.
EngineFactory	getEngineFactory()
IndexAnalyzers	getIndexAnalyzers()
IndexEventListener	getIndexEventListener()
IndexSettings	getIndexSettings()	Returns the index settings of this index.
java.util.function.Supplier<org.apache.lucene.search.Sort>	getIndexSortSupplier()
IndexMetaData	getMetaData()
ScriptService	getScriptService()	The ScriptService to use for this index.
IndexShard	getShard(int shardId)	Return the shard with the provided id, or throw an exception if it doesn't exist.
IndexShard	getShardOrNull(int shardId)	Return the shard with the provided id, or null if there is no such shard.
ThreadPool	getThreadPool()	The ThreadPool to use for this index.
boolean	hasShard(int shardId)
java.lang.String	indexUUID()
java.util.Iterator<IndexShard>	iterator()
MapperService	mapperService()
QueryShardContext	newQueryShardContext(int shardId, org.apache.lucene.index.IndexReader indexReader, java.util.function.LongSupplier nowInMillis, java.lang.String clusterAlias)	Creates a new QueryShardContext.
int	numberOfShards()
void	removeShard(int shardId, java.lang.String reason)	Removes shard with given id.
java.util.Set<java.lang.Integer>	shardIds()
SimilarityService	similarityService()
boolean	updateMapping(IndexMetaData currentIndexMetaData, IndexMetaData newIndexMetaData)	Checks if index requires refresh from master.
void	updateMetaData(IndexMetaData currentIndexMetaData, IndexMetaData newIndexMetaData)	Updates the metadata of this index.
NamedXContentRegistry	xContentRegistry()

Methods inherited from class org.elasticsearch.index.AbstractIndexComponent

index

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.index.IndexComponent

index

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

GLOBAL_CHECKPOINT_SYNC_INTERVAL_SETTING

public static final Setting<TimeValue> GLOBAL_CHECKPOINT_SYNC_INTERVAL_SETTING

RETENTION_LEASE_SYNC_INTERVAL_SETTING

public static final Setting<TimeValue> RETENTION_LEASE_SYNC_INTERVAL_SETTING

Constructor Detail

IndexService

public IndexService(IndexSettings indexSettings,
                    NodeEnvironment nodeEnv,
                    NamedXContentRegistry xContentRegistry,
                    SimilarityService similarityService,
                    IndexService.ShardStoreDeleter shardStoreDeleter,
                    AnalysisRegistry registry,
                    EngineFactory engineFactory,
                    CircuitBreakerService circuitBreakerService,
                    BigArrays bigArrays,
                    ThreadPool threadPool,
                    ScriptService scriptService,
                    Client client,
                    QueryCache queryCache,
                    IndexStore indexStore,
                    IndexEventListener eventListener,
                    IndexModule.IndexSearcherWrapperFactory wrapperFactory,
                    MapperRegistry mapperRegistry,
                    IndicesFieldDataCache indicesFieldDataCache,
                    java.util.List<SearchOperationListener> searchOperationListeners,
                    java.util.List<IndexingOperationListener> indexingOperationListeners,
                    NamedWriteableRegistry namedWriteableRegistry)
             throws java.io.IOException

Throws:

java.io.IOException

Method Detail

numberOfShards

public int numberOfShards()

getIndexEventListener

public IndexEventListener getIndexEventListener()

iterator

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

Specified by:

iterator in interface java.lang.Iterable<IndexShard>

hasShard

public boolean hasShard(int shardId)

getShardOrNull

@Nullable
public IndexShard getShardOrNull(int shardId)

Return the shard with the provided id, or null if there is no such shard.

Specified by:

getShardOrNull in interface IndicesClusterStateService.AllocatedIndex<IndexShard>

getShard

public IndexShard getShard(int shardId)

Return the shard with the provided id, or throw an exception if it doesn't exist.

shardIds

public java.util.Set<java.lang.Integer> shardIds()

cache

public IndexCache cache()

getIndexAnalyzers

public IndexAnalyzers getIndexAnalyzers()

mapperService

public MapperService mapperService()

xContentRegistry

public NamedXContentRegistry xContentRegistry()

similarityService

public SimilarityService similarityService()

getIndexSortSupplier

public java.util.function.Supplier<org.apache.lucene.search.Sort> getIndexSortSupplier()

close

public void close(java.lang.String reason,
                  boolean delete)
           throws java.io.IOException

Throws:

java.io.IOException

indexUUID

public java.lang.String indexUUID()

createShard

public IndexShard createShard(ShardRouting routing,
                              java.util.function.Consumer<ShardId> globalCheckpointSyncer,
                              RetentionLeaseSyncer retentionLeaseSyncer)
                       throws java.io.IOException

Throws:

java.io.IOException

removeShard

public void removeShard(int shardId,
                        java.lang.String reason)

Description copied from interface: IndicesClusterStateService.AllocatedIndex

Removes shard with given id.

Specified by:

removeShard in interface IndicesClusterStateService.AllocatedIndex<IndexShard>

getIndexSettings

public IndexSettings getIndexSettings()

Description copied from interface: IndicesClusterStateService.AllocatedIndex

Returns the index settings of this index.

Specified by:

getIndexSettings in interface IndicesClusterStateService.AllocatedIndex<IndexShard>

Overrides:

getIndexSettings in class AbstractIndexComponent

newQueryShardContext

public QueryShardContext newQueryShardContext(int shardId,
                                              org.apache.lucene.index.IndexReader indexReader,
                                              java.util.function.LongSupplier nowInMillis,
                                              java.lang.String clusterAlias)

Creates a new QueryShardContext. The context has not types set yet, if types are required set them via QueryShardContext.setTypes(String...). Passing a null IndexReader will return a valid context, however it won't be able to make IndexReader-specific optimizations, such as rewriting containing range queries.

getThreadPool

public ThreadPool getThreadPool()

The ThreadPool to use for this index.

getBigArrays

public BigArrays getBigArrays()

The BigArrays to use for this index.

getScriptService

public ScriptService getScriptService()

The ScriptService to use for this index.

updateMapping

public boolean updateMapping(IndexMetaData currentIndexMetaData,
                             IndexMetaData newIndexMetaData)
                      throws java.io.IOException

Description copied from interface: IndicesClusterStateService.AllocatedIndex

Checks if index requires refresh from master.

Specified by:

updateMapping in interface IndicesClusterStateService.AllocatedIndex<IndexShard>

Throws:

java.io.IOException

getMetaData

public IndexMetaData getMetaData()

updateMetaData

public void updateMetaData(IndexMetaData currentIndexMetaData,
                           IndexMetaData newIndexMetaData)

Description copied from interface: IndicesClusterStateService.AllocatedIndex

Updates the metadata of this index. Changes become visible through IndicesClusterStateService.AllocatedIndex.getIndexSettings().

Specified by:

updateMetaData in interface IndicesClusterStateService.AllocatedIndex<IndexShard>

Parameters:

currentIndexMetaData - the current index metadata

newIndexMetaData - the new index metadata

getEngineFactory

public final EngineFactory getEngineFactory()

clearCaches

public boolean clearCaches(boolean queryCache,
                           boolean fieldDataCache,
                           java.lang.String... fields)

Clears the caches for the given shard id if the shard is still allocated on this node