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 | Method and Description |
---|---|
Engine.Searcher |
Engine.acquireSearcher(String source)
Returns a new searcher instance.
|
abstract void |
Engine.create(Engine.Create create) |
void |
InternalEngine.create(Engine.Create create) |
void |
ShadowEngine.create(Engine.Create create) |
abstract void |
Engine.delete(Engine.Delete delete) |
void |
InternalEngine.delete(Engine.Delete delete) |
void |
ShadowEngine.delete(Engine.Delete delete) |
abstract void |
Engine.delete(Engine.DeleteByQuery delete) |
void |
InternalEngine.delete(Engine.DeleteByQuery delete) |
void |
ShadowEngine.delete(Engine.DeleteByQuery delete) |
abstract Engine.CommitId |
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.
|
Engine.CommitId |
InternalEngine.flush() |
Engine.CommitId |
ShadowEngine.flush() |
abstract Engine.CommitId |
Engine.flush(boolean force,
boolean waitIfOngoing)
Flushes the state of the engine including the transaction log, clearing memory.
|
Engine.CommitId |
InternalEngine.flush(boolean force,
boolean waitIfOngoing) |
Engine.CommitId |
ShadowEngine.flush(boolean force,
boolean waitIfOngoing) |
abstract void |
Engine.forceMerge(boolean flush,
int maxNumSegments,
boolean onlyExpungeDeletes,
boolean upgrade,
boolean upgradeOnlyAncientSegments)
Triggers a forced merge on this engine
|
void |
InternalEngine.forceMerge(boolean flush,
int maxNumSegments,
boolean onlyExpungeDeletes,
boolean upgrade,
boolean upgradeOnlyAncientSegments) |
void |
ShadowEngine.forceMerge(boolean flush,
int maxNumSegments,
boolean onlyExpungeDeletes,
boolean upgrade,
boolean upgradeOnlyAncientSegments) |
abstract Engine.GetResult |
Engine.get(Engine.Get get) |
Engine.GetResult |
InternalEngine.get(Engine.Get get) |
Engine.GetResult |
ShadowEngine.get(Engine.Get get) |
protected Engine.GetResult |
Engine.getFromSearcher(Engine.Get get) |
abstract void |
Engine.index(Engine.Index index) |
void |
InternalEngine.index(Engine.Index index) |
void |
ShadowEngine.index(Engine.Index index) |
abstract void |
Engine.maybeMerge() |
void |
InternalEngine.maybeMerge() |
void |
ShadowEngine.maybeMerge() |
protected void |
InternalEngine.maybeUpgrade3xSegments(Store store) |
abstract void |
Engine.recover(Engine.RecoveryHandler recoveryHandler) |
void |
SharedFSEngine.recover(Engine.RecoveryHandler recoveryHandler) |
void |
InternalEngine.recover(Engine.RecoveryHandler recoveryHandler) |
void |
ShadowEngine.recover(Engine.RecoveryHandler recoveryHandler) |
abstract void |
Engine.refresh(String source)
Refreshes the engine for new search operations to reflect the latest
changes.
|
void |
InternalEngine.refresh(String source) |
void |
ShadowEngine.refresh(String source) |
abstract SnapshotIndexCommit |
Engine.snapshotIndex()
Snapshots the index and returns a handle to it.
|
SnapshotIndexCommit |
InternalEngine.snapshotIndex() |
SnapshotIndexCommit |
ShadowEngine.snapshotIndex() |
abstract Engine.SyncedFlushResult |
Engine.syncFlush(String syncId,
Engine.CommitId expectedCommitId)
Attempts to do a special commit where the given syncID is put into the commit data.
|
Engine.SyncedFlushResult |
InternalEngine.syncFlush(String syncId,
Engine.CommitId expectedCommitId) |
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–2016. All rights reserved.