public class ShardIndexingService extends AbstractIndexShardComponent
componentSettings, indexSettings, logger, shardId
Constructor and Description |
---|
ShardIndexingService(ShardId shardId,
Settings indexSettings,
ShardSlowLogIndexingService slowLog) |
Modifier and Type | Method and Description |
---|---|
void |
addListener(IndexingOperationListener listener) |
void |
clear() |
void |
failedDelete(Engine.Delete delete) |
void |
failedIndex(Engine.Index index) |
void |
noopUpdate(String type) |
void |
postCreate(Engine.Create create) |
void |
postCreateUnderLock(Engine.Create create) |
void |
postDelete(Engine.Delete delete) |
void |
postDeleteByQuery(Engine.DeleteByQuery deleteByQuery) |
void |
postDeleteUnderLock(Engine.Delete delete) |
void |
postIndex(Engine.Index index) |
void |
postIndexUnderLock(Engine.Index index) |
Engine.Create |
preCreate(Engine.Create create) |
Engine.Delete |
preDelete(Engine.Delete delete) |
Engine.DeleteByQuery |
preDeleteByQuery(Engine.DeleteByQuery deleteByQuery) |
Engine.Index |
preIndex(Engine.Index index) |
void |
removeListener(IndexingOperationListener listener) |
IndexingStats |
stats(String... types)
Returns the stats, including type specific stats.
|
void |
throttlingActivated() |
void |
throttlingDeactivated() |
indexSettings, nodeName, shardId
@Inject public ShardIndexingService(ShardId shardId, @IndexSettings Settings indexSettings, ShardSlowLogIndexingService slowLog)
public IndexingStats stats(String... types)
public void addListener(IndexingOperationListener listener)
public void removeListener(IndexingOperationListener listener)
public Engine.Create preCreate(Engine.Create create)
public void postCreateUnderLock(Engine.Create create)
public void throttlingActivated()
public void throttlingDeactivated()
public void postCreate(Engine.Create create)
public Engine.Index preIndex(Engine.Index index)
public void postIndexUnderLock(Engine.Index index)
public void postIndex(Engine.Index index)
public void failedIndex(Engine.Index index)
public Engine.Delete preDelete(Engine.Delete delete)
public void postDeleteUnderLock(Engine.Delete delete)
public void postDelete(Engine.Delete delete)
public void failedDelete(Engine.Delete delete)
public Engine.DeleteByQuery preDeleteByQuery(Engine.DeleteByQuery deleteByQuery)
public void postDeleteByQuery(Engine.DeleteByQuery deleteByQuery)
public void noopUpdate(String type)
public void clear()
Copyright © 2009–2015. All rights reserved.