org.elasticsearch.index.indexing
Class IndexingOperationListener

java.lang.Object
  org.elasticsearch.index.indexing.IndexingOperationListener

public abstract class IndexingOperationListener
extends Object

An indexing listener for indexing, delete, events.

Constructor Summary

IndexingOperationListener()

Method Summary

void	postCreate(Engine.Create create) Called after the indexing operation occurred.
void	postCreateUnderLock(Engine.Create create) Called after the indexing occurs, under a locking scheme to maintain concurrent updates to the same doc.
void	postDelete(Engine.Delete delete) Called after the delete operation occurred.
void	postDeleteByQuery(Engine.DeleteByQuery deleteByQuery)
void	postDeleteUnderLock(Engine.Delete delete) Called after the delete occurs, under a locking scheme to maintain concurrent updates to the same doc.
void	postIndex(Engine.Index index) Called after the indexing operation occurred.
void	postIndexUnderLock(Engine.Index index) Called after the indexing occurs, under a locking scheme to maintain concurrent updates to the same doc.
Engine.Create	preCreate(Engine.Create create) Called before the indexing occurs.
Engine.Delete	preDelete(Engine.Delete delete) Called before the delete occurs.
Engine.DeleteByQuery	preDeleteByQuery(Engine.DeleteByQuery deleteByQuery)
Engine.Index	preIndex(Engine.Index index) Called before the indexing occurs.

Methods inherited from class java.lang.Object

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

Constructor Detail

IndexingOperationListener

public IndexingOperationListener()

Method Detail

preCreate

public Engine.Create preCreate(Engine.Create create)

Called before the indexing occurs.

postCreateUnderLock

public void postCreateUnderLock(Engine.Create create)

Called after the indexing occurs, under a locking scheme to maintain concurrent updates to the same doc.

Note, long operations should not occur under this callback.

postCreate

public void postCreate(Engine.Create create)

Called after the indexing operation occurred.

preIndex

public Engine.Index preIndex(Engine.Index index)

Called before the indexing occurs.

postIndexUnderLock

public void postIndexUnderLock(Engine.Index index)

Called after the indexing occurs, under a locking scheme to maintain concurrent updates to the same doc.

Note, long operations should not occur under this callback.

postIndex

public void postIndex(Engine.Index index)

Called after the indexing operation occurred.

preDelete

public Engine.Delete preDelete(Engine.Delete delete)

Called before the delete occurs.

postDeleteUnderLock

public void postDeleteUnderLock(Engine.Delete delete)

Called after the delete occurs, under a locking scheme to maintain concurrent updates to the same doc.

Note, long operations should not occur under this callback.

postDelete

public void postDelete(Engine.Delete delete)

Called after the delete operation occurred.

preDeleteByQuery

public Engine.DeleteByQuery preDeleteByQuery(Engine.DeleteByQuery deleteByQuery)

postDeleteByQuery

public void postDeleteByQuery(Engine.DeleteByQuery deleteByQuery)