org.elasticsearch.index.engine

Class InternalEngine

java.lang.Object

org.elasticsearch.index.engine.Engine

org.elasticsearch.index.engine.InternalEngine

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

SharedFSEngine

public class InternalEngine
extends Engine

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.index.engine.Engine

Engine.CommitId, Engine.Create, Engine.Delete, Engine.DeleteByQuery, Engine.FailedEngineListener, Engine.Get, Engine.GetResult, Engine.Index, Engine.IndexingOperation, Engine.IndexThrottle, Engine.NoOpLock, Engine.Operation, Engine.RecoveryHandler, Engine.Searcher, Engine.SyncedFlushResult

Field Summary

Fields

Modifier and Type	Field and Description
protected FlushingRecoveryCounter	onGoingRecoveries

Fields inherited from class org.elasticsearch.index.engine.Engine

deletionPolicy, engineConfig, failedEngine, failedEngineListener, failEngineLock, isClosed, logger, readLock, rwl, shardId, store, SYNC_COMMIT_ID, writeLock

Constructor Summary

Constructors

Constructor and Description
InternalEngine(EngineConfig engineConfig)

Method Summary

Modifier and Type	Method and Description
void	activateThrottling()
protected void	closeNoLock(String reason) Closes the engine without acquiring the write lock.
void	create(Engine.Create create)
void	deactivateThrottling()
void	delete(Engine.Delete delete)
void	delete(Engine.DeleteByQuery delete)
Engine.CommitId	flush() Flushes the state of the engine including the transaction log, clearing memory and persisting documents in the lucene index to disk including a potentially heavy and durable fsync operation.
Engine.CommitId	flush(boolean force, boolean waitIfOngoing) Flushes the state of the engine including the transaction log, clearing memory.
void	forceMerge(boolean flush, int maxNumSegments, boolean onlyExpungeDeletes, boolean upgrade, boolean upgradeOnlyAncientSegments) Triggers a forced merge on this engine
Engine.GetResult	get(Engine.Get get)
protected org.apache.lucene.index.SegmentInfos	getLastCommittedSegmentInfos()
protected org.apache.lucene.search.SearcherManager	getSearcherManager()
boolean	hasUncommittedChanges() Returns true the internal writer has any uncommitted changes.
void	index(Engine.Index index)
protected boolean	maybeFailEngine(String source, Throwable t) Check whether the engine should be failed
void	maybeMerge()
protected void	maybeUpgrade3xSegments(Store store)
boolean	possibleMergeNeeded() Returns true if a possible merge is really needed.
void	recover(Engine.RecoveryHandler recoveryHandler)
void	refresh(String source) Refreshes the engine for new search operations to reflect the latest changes.
List<Segment>	segments() The list of segments in the engine.
SnapshotIndexCommit	snapshotIndex() Snapshots the index and returns a handle to it.
Engine.SyncedFlushResult	syncFlush(String syncId, Engine.CommitId expectedCommitId) Attempts to do a special commit where the given syncID is put into the commit data.
protected void	writerSegmentStats(SegmentsStats stats)

Methods inherited from class org.elasticsearch.index.engine.Engine

acquireSearcher, close, commitStats, config, ensureOpen, failEngine, flushAndClose, forceMerge, getFromSearcher, getSegmentInfo, guardedRamBytesUsed, isMergedSegment, newSearcher, refreshNeeded, segmentsStats, wrapIfClosed

Methods inherited from class java.lang.Object

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

Field Detail

onGoingRecoveries

protected final FlushingRecoveryCounter onGoingRecoveries

Constructor Detail

InternalEngine

public InternalEngine(EngineConfig engineConfig)
               throws EngineException

Throws:

EngineException

Method Detail

get

public Engine.GetResult get(Engine.Get get)
                     throws EngineException

Specified by:

get in class Engine

Throws:

EngineException

create

public void create(Engine.Create create)
            throws EngineException

Specified by:

create in class Engine

Throws:

EngineException

index

public void index(Engine.Index index)
           throws EngineException

Specified by:

index in class Engine

Throws:

EngineException

delete

public void delete(Engine.Delete delete)
            throws EngineException

Specified by:

delete in class Engine

Throws:

EngineException

delete

public void delete(Engine.DeleteByQuery delete)
            throws EngineException

Specified by:

delete in class Engine

Throws:

EngineException

refresh

public void refresh(String source)
             throws EngineException

Description copied from class: Engine

Refreshes the engine for new search operations to reflect the latest changes.

Specified by:

refresh in class Engine

Throws:

EngineException

syncFlush

public Engine.SyncedFlushResult syncFlush(String syncId,
                                          Engine.CommitId expectedCommitId)
                                   throws EngineException

Description copied from class: Engine

Attempts to do a special commit where the given syncID is put into the commit data. The attempt succeeds if there are not pending writes in lucene and the current point is equal to the expected one.

Specified by:

syncFlush in class Engine

Parameters:

syncId - id of this sync

expectedCommitId - the expected value of

Returns:

true if the sync commit was made, false o.w.

Throws:

EngineException

flush

public Engine.CommitId flush()
                      throws EngineException

Description copied from class: Engine

Flushes the state of the engine including the transaction log, clearing memory and persisting documents in the lucene index to disk including a potentially heavy and durable fsync operation. This operation is not going to block if another flush operation is currently running and won't write a lucene commit if nothing needs to be committed.

Specified by:

flush in class Engine

Returns:

the commit Id for the resulting commit

Throws:

EngineException

flush

public Engine.CommitId flush(boolean force,
                             boolean waitIfOngoing)
                      throws EngineException

Description copied from class: Engine

Flushes the state of the engine including the transaction log, clearing memory.

Specified by:

flush in class Engine

Parameters:

force - if true a lucene commit is executed even if no changes need to be committed.

waitIfOngoing - if true this call will block until all currently running flushes have finished. Otherwise this call will return without blocking.

Returns:

the commit Id for the resulting commit

Throws:

EngineException

possibleMergeNeeded

public boolean possibleMergeNeeded()

Description copied from class: Engine

Returns true if a possible merge is really needed.

Specified by:

possibleMergeNeeded in class Engine

maybeMerge

public void maybeMerge()
                throws EngineException

Specified by:

maybeMerge in class Engine

Throws:

EngineException

forceMerge

public void forceMerge(boolean flush,
                       int maxNumSegments,
                       boolean onlyExpungeDeletes,
                       boolean upgrade,
                       boolean upgradeOnlyAncientSegments)
                throws EngineException

Description copied from class: Engine

Triggers a forced merge on this engine

Specified by:

forceMerge in class Engine

Throws:

EngineException

snapshotIndex

public SnapshotIndexCommit snapshotIndex()
                                  throws EngineException

Description copied from class: Engine

Snapshots the index and returns a handle to it. Will always try and "commit" the lucene index to make sure we have a "fresh" copy of the files to snapshot.

Specified by:

snapshotIndex in class Engine

Throws:

EngineException

recover

public void recover(Engine.RecoveryHandler recoveryHandler)
             throws EngineException

Specified by:

recover in class Engine

Throws:

EngineException

maybeFailEngine

protected boolean maybeFailEngine(String source,
                                  Throwable t)

Description copied from class: Engine

Check whether the engine should be failed

Overrides:

maybeFailEngine in class Engine

getLastCommittedSegmentInfos

protected org.apache.lucene.index.SegmentInfos getLastCommittedSegmentInfos()

Specified by:

getLastCommittedSegmentInfos in class Engine

writerSegmentStats

protected final void writerSegmentStats(SegmentsStats stats)

Overrides:

writerSegmentStats in class Engine

segments

public List<Segment> segments()

Description copied from class: Engine

The list of segments in the engine.

Specified by:

segments in class Engine

closeNoLock

protected final void closeNoLock(String reason)
                          throws ElasticsearchException

Closes the engine without acquiring the write lock. This should only be called while the write lock is hold or in a disaster condition ie. if the engine is failed.

Specified by:

closeNoLock in class Engine

Throws:

ElasticsearchException

hasUncommittedChanges

public boolean hasUncommittedChanges()

Description copied from class: Engine

Returns true the internal writer has any uncommitted changes. Otherwise false

Specified by:

hasUncommittedChanges in class Engine

Returns:

getSearcherManager

protected org.apache.lucene.search.SearcherManager getSearcherManager()

Specified by:

getSearcherManager in class Engine

maybeUpgrade3xSegments

protected void maybeUpgrade3xSegments(Store store)
                               throws EngineException

Throws:

EngineException

activateThrottling

public void activateThrottling()

deactivateThrottling

public void deactivateThrottling()