org.elasticsearch.index.engine

Class EngineConfig

java.lang.Object

org.elasticsearch.index.engine.EngineConfig

public final class EngineConfig
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	EngineConfig.OpenMode Engine open mode defines how the engine should be opened or in other words what the engine should expect to recover from.

Field Summary

Fields

Modifier and Type	Field and Description
static Setting<java.lang.String>	INDEX_CODEC_SETTING Index setting to change the low level lucene codec used for writing new segments.
static Setting<java.lang.Boolean>	INDEX_OPTIMIZE_AUTO_GENERATED_IDS Configures an index to optimize documents with auto generated ids for append only.

Constructor Summary

Constructors

Constructor and Description

EngineConfig(EngineConfig.OpenMode openMode, ShardId shardId, ThreadPool threadPool, IndexSettings indexSettings, Engine.Warmer warmer, Store store, org.apache.lucene.index.SnapshotDeletionPolicy deletionPolicy, org.apache.lucene.index.MergePolicy mergePolicy, org.apache.lucene.analysis.Analyzer analyzer, org.apache.lucene.search.similarities.Similarity similarity, CodecService codecService, Engine.EventListener eventListener, TranslogRecoveryPerformer translogRecoveryPerformer, org.apache.lucene.search.QueryCache queryCache, org.apache.lucene.search.QueryCachingPolicy queryCachingPolicy, TranslogConfig translogConfig, TimeValue flushMergesAfter, java.util.List<org.apache.lucene.search.ReferenceManager.RefreshListener> refreshListeners, long maxUnsafeAutoIdTimestamp) Creates a new EngineConfig

Method Summary

Modifier and Type	Method and Description
org.apache.lucene.analysis.Analyzer	getAnalyzer() Returns the analyzer as the default analyzer in the engines IndexWriter
org.apache.lucene.codecs.Codec	getCodec() Returns the Codec used in the engines IndexWriter
org.apache.lucene.index.SnapshotDeletionPolicy	getDeletionPolicy() Returns a SnapshotDeletionPolicy used in the engines IndexWriter.
Engine.EventListener	getEventListener() Returns a listener that should be called on engine failure
TimeValue	getFlushMergesAfter() Returns a TimeValue at what time interval after the last write modification to the engine finished merges should be automatically flushed.
ByteSizeValue	getIndexingBufferSize() Returns the initial index buffer size.
IndexSettings	getIndexSettings() Returns the index settings for this index.
long	getMaxUnsafeAutoIdTimestamp() Returns the max timestamp that is used to de-optimize documents with auto-generated IDs in the engine.
org.apache.lucene.index.MergePolicy	getMergePolicy() Returns the MergePolicy for the engines IndexWriter
EngineConfig.OpenMode	getOpenMode() Returns the EngineConfig.OpenMode for this engine config.
org.apache.lucene.search.QueryCache	getQueryCache() Return the cache to use for queries.
org.apache.lucene.search.QueryCachingPolicy	getQueryCachingPolicy() Return the policy to use when caching queries.
java.util.List<org.apache.lucene.search.ReferenceManager.RefreshListener>	getRefreshListeners() The refresh listeners to add to Lucene
ShardId	getShardId() Returns the engines shard ID
org.apache.lucene.search.similarities.Similarity	getSimilarity() Returns the Similarity used for indexing and searching.
Store	getStore() Returns the Store instance that provides access to the Directory used for the engines IndexWriter to write it's index files to.
ThreadPool	getThreadPool() Returns a thread-pool mainly used to get estimated time stamps from ThreadPool.relativeTimeInMillis() and to schedule async force merge calls on the ThreadPool.Names.FORCE_MERGE thread-pool
TranslogConfig	getTranslogConfig() Returns the translog config for this engine
TranslogRecoveryPerformer	getTranslogRecoveryPerformer() Returns the TranslogRecoveryPerformer for this engine.
Engine.Warmer	getWarmer() Returns an Engine.Warmer used to warm new searchers before they are used for searching.
boolean	isEnableGcDeletes() Returns true iff delete garbage collection in the engine should be enabled.
void	setEnableGcDeletes(boolean enableGcDeletes) Enables / disables gc deletes

Methods inherited from class java.lang.Object

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

Field Detail

INDEX_CODEC_SETTING

public static final Setting<java.lang.String> INDEX_CODEC_SETTING

Index setting to change the low level lucene codec used for writing new segments. This setting is not realtime updateable. This setting is also settable on the node and the index level, it's commonly used in hot/cold node archs where index is likely allocated on both `kind` of nodes.

INDEX_OPTIMIZE_AUTO_GENERATED_IDS

public static final Setting<java.lang.Boolean> INDEX_OPTIMIZE_AUTO_GENERATED_IDS

Configures an index to optimize documents with auto generated ids for append only. If this setting is updated from false to true might not take effect immediately. In other words, disabling the optimiation will be immediately applied while re-enabling it might not be applied until the engine is in a safe state to do so. Depending on the engine implementation a change to this setting won't be reflected re-enabled optimization until the engine is restarted or the index is closed and reopened. The default is true

Constructor Detail

EngineConfig

public EngineConfig(EngineConfig.OpenMode openMode,
                    ShardId shardId,
                    ThreadPool threadPool,
                    IndexSettings indexSettings,
                    Engine.Warmer warmer,
                    Store store,
                    org.apache.lucene.index.SnapshotDeletionPolicy deletionPolicy,
                    org.apache.lucene.index.MergePolicy mergePolicy,
                    org.apache.lucene.analysis.Analyzer analyzer,
                    org.apache.lucene.search.similarities.Similarity similarity,
                    CodecService codecService,
                    Engine.EventListener eventListener,
                    TranslogRecoveryPerformer translogRecoveryPerformer,
                    org.apache.lucene.search.QueryCache queryCache,
                    org.apache.lucene.search.QueryCachingPolicy queryCachingPolicy,
                    TranslogConfig translogConfig,
                    TimeValue flushMergesAfter,
                    java.util.List<org.apache.lucene.search.ReferenceManager.RefreshListener> refreshListeners,
                    long maxUnsafeAutoIdTimestamp)

Creates a new EngineConfig

Method Detail

setEnableGcDeletes

public void setEnableGcDeletes(boolean enableGcDeletes)

Enables / disables gc deletes

See Also:

isEnableGcDeletes()

getIndexingBufferSize

public ByteSizeValue getIndexingBufferSize()

Returns the initial index buffer size. This setting is only read on startup and otherwise controlled by IndexingMemoryController

isEnableGcDeletes

public boolean isEnableGcDeletes()

Returns true iff delete garbage collection in the engine should be enabled. This setting is updateable in realtime and forces a volatile read. Consumers can safely read this value directly go fetch it's latest value. The default is true

Engine GC deletion if enabled collects deleted documents from in-memory realtime data structures after a certain amount of time (IndexSettings.getGcDeletesInMillis() if enabled. Before deletes are GCed they will cause re-adding the document that was deleted to fail.

getCodec

public org.apache.lucene.codecs.Codec getCodec()

Returns the Codec used in the engines IndexWriter

Note: this settings is only read on startup.

getThreadPool

public ThreadPool getThreadPool()

Returns a thread-pool mainly used to get estimated time stamps from ThreadPool.relativeTimeInMillis() and to schedule async force merge calls on the ThreadPool.Names.FORCE_MERGE thread-pool

getWarmer

public Engine.Warmer getWarmer()

Returns an Engine.Warmer used to warm new searchers before they are used for searching.

getStore

public Store getStore()

Returns the Store instance that provides access to the Directory used for the engines IndexWriter to write it's index files to.

Note: In order to use this instance the consumer needs to increment the stores reference before it's used the first time and hold it's reference until it's not needed anymore.

getDeletionPolicy

public org.apache.lucene.index.SnapshotDeletionPolicy getDeletionPolicy()

Returns a SnapshotDeletionPolicy used in the engines IndexWriter.

getMergePolicy

public org.apache.lucene.index.MergePolicy getMergePolicy()

Returns the MergePolicy for the engines IndexWriter

getEventListener

public Engine.EventListener getEventListener()

Returns a listener that should be called on engine failure

getIndexSettings

public IndexSettings getIndexSettings()

Returns the index settings for this index.

getShardId

public ShardId getShardId()

Returns the engines shard ID

getAnalyzer

public org.apache.lucene.analysis.Analyzer getAnalyzer()

Returns the analyzer as the default analyzer in the engines IndexWriter

getSimilarity

public org.apache.lucene.search.similarities.Similarity getSimilarity()

Returns the Similarity used for indexing and searching.

getTranslogRecoveryPerformer

public TranslogRecoveryPerformer getTranslogRecoveryPerformer()

Returns the TranslogRecoveryPerformer for this engine. This class is used to apply transaction log operations to the engine. It encapsulates all the logic to transfer the translog entry into an indexing operation.

getQueryCache

public org.apache.lucene.search.QueryCache getQueryCache()

Return the cache to use for queries.

getQueryCachingPolicy

public org.apache.lucene.search.QueryCachingPolicy getQueryCachingPolicy()

Return the policy to use when caching queries.

getTranslogConfig

public TranslogConfig getTranslogConfig()

Returns the translog config for this engine

getFlushMergesAfter

public TimeValue getFlushMergesAfter()

Returns a TimeValue at what time interval after the last write modification to the engine finished merges should be automatically flushed. This is used to free up transient disk usage of potentially large segments that are written after the engine became inactive from an indexing perspective.

getOpenMode

public EngineConfig.OpenMode getOpenMode()

Returns the EngineConfig.OpenMode for this engine config.

getRefreshListeners

public java.util.List<org.apache.lucene.search.ReferenceManager.RefreshListener> getRefreshListeners()

The refresh listeners to add to Lucene

getMaxUnsafeAutoIdTimestamp

public long getMaxUnsafeAutoIdTimestamp()

Returns the max timestamp that is used to de-optimize documents with auto-generated IDs in the engine. This is used to ensure we don't add duplicate documents when we assume an append only case based on auto-generated IDs