org.elasticsearch.index.engine.robin
Class RobinEngine

java.lang.Object
  org.elasticsearch.index.shard.AbstractIndexShardComponent
      org.elasticsearch.index.engine.robin.RobinEngine

All Implemented Interfaces:

CloseableComponent, Engine, IndexShardComponent

public class RobinEngine
extends AbstractIndexShardComponent
implements Engine

Nested Class Summary

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

Engine.Create, Engine.Delete, Engine.DeleteByQuery, Engine.FailedEngineListener, Engine.Flush, Engine.Get, Engine.GetResult, Engine.Index, Engine.IndexingOperation, Engine.Operation, Engine.Optimize, Engine.RecoveryHandler, Engine.Refresh, Engine.Searcher, Engine.SimpleSearcher, Engine.SnapshotHandler<T>

Field Summary

Fields inherited from class org.elasticsearch.index.shard.AbstractIndexShardComponent

componentSettings, indexSettings, logger, shardId

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

INACTIVE_SHARD_INDEXING_BUFFER

Constructor Summary

RobinEngine(ShardId shardId, Settings indexSettings, ThreadPool threadPool, IndexSettingsService indexSettingsService, ShardIndexingService indexingService, IndicesWarmer warmer, Store store, SnapshotDeletionPolicy deletionPolicy, Translog translog, MergePolicyProvider mergePolicyProvider, MergeSchedulerProvider mergeScheduler, AnalysisService analysisService, SimilarityService similarityService, BloomCache bloomCache)

Method Summary

void	addFailedEngineListener(Engine.FailedEngineListener listener)
void	close()
void	create(Engine.Create create)
TimeValue	defaultRefreshInterval() The default suggested refresh interval, -1 to disable it.
void	delete(Engine.Delete delete)
void	delete(Engine.DeleteByQuery delete)
void	enableGcDeletes(boolean enableGcDeletes)
void	flush(Engine.Flush flush) Flushes the state of the engine, clearing memory.
Engine.GetResult	get(Engine.Get get)
void	index(Engine.Index index)
void	maybeMerge()
void	optimize(Engine.Optimize optimize)
boolean	possibleMergeNeeded() Returns true if a possible merge is really needed.
void	recover(Engine.RecoveryHandler recoveryHandler)
void	refresh(Engine.Refresh refresh) Refreshes the engine for new search operations to reflect the latest changes.
boolean	refreshNeeded() Returns true if a refresh is really needed.
Engine.Searcher	searcher()
List<Segment>	segments()
<T> T	snapshot(Engine.SnapshotHandler<T> snapshotHandler)
void	start() Starts the Engine.
void	updateIndexingBufferSize(ByteSizeValue indexingBufferSize)

Methods inherited from class org.elasticsearch.index.shard.AbstractIndexShardComponent

indexSettings, managementGroupName, nodeName, shardId

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.shard.IndexShardComponent

indexSettings, shardId

Constructor Detail

RobinEngine

@Inject
public RobinEngine(ShardId shardId,
                          @IndexSettings
                          Settings indexSettings,
                          ThreadPool threadPool,
                          IndexSettingsService indexSettingsService,
                          ShardIndexingService indexingService,
                          @Nullable
                          IndicesWarmer warmer,
                          Store store,
                          SnapshotDeletionPolicy deletionPolicy,
                          Translog translog,
                          MergePolicyProvider mergePolicyProvider,
                          MergeSchedulerProvider mergeScheduler,
                          AnalysisService analysisService,
                          SimilarityService similarityService,
                          BloomCache bloomCache)
            throws EngineException

Throws:

EngineException

Method Detail

updateIndexingBufferSize

public void updateIndexingBufferSize(ByteSizeValue indexingBufferSize)

Specified by:

updateIndexingBufferSize in interface Engine

addFailedEngineListener

public void addFailedEngineListener(Engine.FailedEngineListener listener)

Specified by:

addFailedEngineListener in interface Engine

start

public void start()
           throws EngineException

Description copied from interface: Engine

Starts the Engine.

Note, after the creation and before the call to start, the store might be changed.

Specified by:

start in interface Engine

Throws:

EngineException

defaultRefreshInterval

public TimeValue defaultRefreshInterval()

Description copied from interface: Engine

The default suggested refresh interval, -1 to disable it.

Specified by:

defaultRefreshInterval in interface Engine

enableGcDeletes

public void enableGcDeletes(boolean enableGcDeletes)

Specified by:

enableGcDeletes in interface Engine

get

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

Specified by:

get in interface Engine

Throws:

EngineException

create

public void create(Engine.Create create)
            throws EngineException

Specified by:

create in interface Engine

Throws:

EngineException

index

public void index(Engine.Index index)
           throws EngineException

Specified by:

index in interface Engine

Throws:

EngineException

delete

public void delete(Engine.Delete delete)
            throws EngineException

Specified by:

delete in interface Engine

Throws:

EngineException

delete

public void delete(Engine.DeleteByQuery delete)
            throws EngineException

Specified by:

delete in interface Engine

Throws:

EngineException

searcher

public Engine.Searcher searcher()
                         throws EngineException

Specified by:

searcher in interface Engine

Throws:

EngineException

refreshNeeded

public boolean refreshNeeded()

Description copied from interface: Engine

Returns true if a refresh is really needed.

Specified by:

refreshNeeded in interface Engine

possibleMergeNeeded

public boolean possibleMergeNeeded()

Description copied from interface: Engine

Returns true if a possible merge is really needed.

Specified by:

possibleMergeNeeded in interface Engine

refresh

public void refresh(Engine.Refresh refresh)
             throws EngineException

Description copied from interface: Engine

Refreshes the engine for new search operations to reflect the latest changes. Pass true if the refresh operation should include all the operations performed up to this call.

Specified by:

refresh in interface Engine

Throws:

EngineException

flush

public void flush(Engine.Flush flush)
           throws EngineException

Description copied from interface: Engine

Flushes the state of the engine, clearing memory.

Specified by:

flush in interface Engine

Throws:

EngineException

maybeMerge

public void maybeMerge()
                throws EngineException

Specified by:

maybeMerge in interface Engine

Throws:

EngineException

optimize

public void optimize(Engine.Optimize optimize)
              throws EngineException

Specified by:

optimize in interface Engine

Throws:

EngineException

snapshot

public <T> T snapshot(Engine.SnapshotHandler<T> snapshotHandler)
           throws EngineException

Specified by:

snapshot in interface Engine

Throws:

EngineException

recover

public void recover(Engine.RecoveryHandler recoveryHandler)
             throws EngineException

Specified by:

recover in interface Engine

Throws:

EngineException

segments

public List<Segment> segments()

Specified by:

segments in interface Engine

close

public void close()
           throws ElasticSearchException

Specified by:

close in interface CloseableComponent

Throws:

ElasticSearchException