Package | Description |
---|---|
org.elasticsearch.common.util.concurrent | |
org.elasticsearch.index.engine | |
org.elasticsearch.index.shard |
Modifier and Type | Method and Description |
---|---|
ReleasableLock |
ReleasableLock.acquire() |
Modifier and Type | Class and Description |
---|---|
class |
CloseEngineException
An exception indicating that an
Engine close failed. |
class |
CreateFailedEngineException |
class |
DeleteByQueryFailedEngineException |
class |
DeleteFailedEngineException |
class |
DocumentAlreadyExistsException |
class |
DocumentMissingException |
class |
DocumentSourceMissingException |
class |
EngineAlreadyStartedException |
class |
EngineCreationFailureException
An exception indicating that an
Engine creation failed. |
class |
FlushFailedEngineException |
class |
FlushNotAllowedEngineException |
class |
IndexFailedEngineException |
class |
OptimizeFailedEngineException |
class |
RecoveryEngineException |
class |
RefreshFailedEngineException |
class |
RollbackFailedEngineException |
class |
RollbackNotAllowedEngineException |
class |
SnapshotFailedEngineException |
class |
VersionConflictEngineException |
Modifier and Type | Method and Description |
---|---|
Engine.Searcher |
Engine.acquireSearcher(String source)
Returns a new searcher instance.
|
void |
InternalEngine.create(Engine.Create create) |
void |
ShadowEngine.create(Engine.Create create) |
abstract void |
Engine.create(Engine.Create create) |
void |
InternalEngine.delete(Engine.Delete delete) |
void |
ShadowEngine.delete(Engine.Delete delete) |
abstract void |
Engine.delete(Engine.Delete delete) |
void |
InternalEngine.delete(Engine.DeleteByQuery delete) |
void |
ShadowEngine.delete(Engine.DeleteByQuery delete) |
abstract void |
Engine.delete(Engine.DeleteByQuery delete) |
void |
InternalEngine.flush() |
void |
ShadowEngine.flush() |
abstract void |
Engine.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.
|
void |
InternalEngine.flush(boolean force,
boolean waitIfOngoing) |
void |
ShadowEngine.flush(boolean force,
boolean waitIfOngoing) |
abstract void |
Engine.flush(boolean force,
boolean waitIfOngoing)
Flushes the state of the engine including the transaction log, clearing memory.
|
void |
InternalEngine.forceMerge(boolean flush,
int maxNumSegments,
boolean onlyExpungeDeletes,
boolean upgrade) |
void |
ShadowEngine.forceMerge(boolean flush,
int maxNumSegments,
boolean onlyExpungeDeletes,
boolean upgrade) |
abstract void |
Engine.forceMerge(boolean flush,
int maxNumSegments,
boolean onlyExpungeDeletes,
boolean upgrade)
Triggers a forced merge on this engine
|
Engine.GetResult |
InternalEngine.get(Engine.Get get) |
Engine.GetResult |
ShadowEngine.get(Engine.Get get) |
abstract Engine.GetResult |
Engine.get(Engine.Get get) |
protected Engine.GetResult |
Engine.getFromSearcher(Engine.Get get) |
void |
InternalEngine.index(Engine.Index index) |
void |
ShadowEngine.index(Engine.Index index) |
abstract void |
Engine.index(Engine.Index index) |
void |
InternalEngine.maybeMerge() |
void |
ShadowEngine.maybeMerge() |
abstract void |
Engine.maybeMerge() |
void |
InternalEngine.recover(Engine.RecoveryHandler recoveryHandler) |
void |
ShadowEngine.recover(Engine.RecoveryHandler recoveryHandler) |
abstract void |
Engine.recover(Engine.RecoveryHandler recoveryHandler) |
void |
SharedFSEngine.recover(Engine.RecoveryHandler recoveryHandler) |
void |
InternalEngine.refresh(String source) |
void |
ShadowEngine.refresh(String source) |
abstract void |
Engine.refresh(String source)
Refreshes the engine for new search operations to reflect the latest
changes.
|
SnapshotIndexCommit |
InternalEngine.snapshotIndex() |
SnapshotIndexCommit |
ShadowEngine.snapshotIndex() |
abstract SnapshotIndexCommit |
Engine.snapshotIndex()
Snapshots the index and returns a handle to it.
|
Constructor and Description |
---|
InternalEngine(EngineConfig engineConfig) |
SharedFSEngine(EngineConfig engineConfig) |
Modifier and Type | Method and Description |
---|---|
void |
IndexShard.recover(Engine.RecoveryHandler recoveryHandler) |
SnapshotIndexCommit |
IndexShard.snapshotIndex() |
Copyright © 2009–2015. All rights reserved.