Package org.elasticsearch.index.shard

Class IndexingOperationListener.CompositeListener

java.lang.Object

org.elasticsearch.index.shard.IndexingOperationListener.CompositeListener

All Implemented Interfaces:

IndexingOperationListener

Enclosing interface:

IndexingOperationListener

public static final class IndexingOperationListener.CompositeListener
extends Object
implements IndexingOperationListener

A Composite listener that multiplexes calls to each of the listeners methods.

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.index.shard.IndexingOperationListener

IndexingOperationListener.CompositeListener

Constructor Summary

Constructors

Constructor	Description
CompositeListener(List<IndexingOperationListener> listeners, org.apache.logging.log4j.Logger logger)

Method Summary

Modifier and Type	Method	Description
void	postDelete(ShardId shardId, Engine.Delete delete, Exception ex)	Called after the delete operation occurred with engine level exception.
void	postDelete(ShardId shardId, Engine.Delete delete, Engine.DeleteResult result)	Called after the delete operation occurred.
void	postIndex(ShardId shardId, Engine.Index index, Exception ex)	Called after the indexing operation occurred with engine level exception.
void	postIndex(ShardId shardId, Engine.Index index, Engine.IndexResult result)	Called after the indexing operation occurred.
Engine.Delete	preDelete(ShardId shardId, Engine.Delete delete)	Called before the delete occurs.
Engine.Index	preIndex(ShardId shardId, Engine.Index operation)	Called before the indexing occurs.

Methods inherited from class java.lang.Object

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

Constructor Details

CompositeListener

public CompositeListener(List<IndexingOperationListener> listeners,
 org.apache.logging.log4j.Logger logger)

Method Details

preIndex

public Engine.Index preIndex(ShardId shardId,
 Engine.Index operation)

Description copied from interface: IndexingOperationListener

Called before the indexing occurs.

Specified by:

preIndex in interface IndexingOperationListener

postIndex

public void postIndex(ShardId shardId,
 Engine.Index index,
 Engine.IndexResult result)

Description copied from interface: IndexingOperationListener

Called after the indexing operation occurred. Note that this is also called when indexing a document did not succeed due to document related failures. See IndexingOperationListener.postIndex(ShardId, Engine.Index, Exception) for engine level failures

Specified by:

postIndex in interface IndexingOperationListener

postIndex

public void postIndex(ShardId shardId,
 Engine.Index index,
 Exception ex)

Description copied from interface: IndexingOperationListener

Called after the indexing operation occurred with engine level exception. See IndexingOperationListener.postIndex(ShardId, Engine.Index, Engine.IndexResult) for document related failures

Specified by:

postIndex in interface IndexingOperationListener

preDelete

public Engine.Delete preDelete(ShardId shardId,
 Engine.Delete delete)

Description copied from interface: IndexingOperationListener

Called before the delete occurs.

Specified by:

preDelete in interface IndexingOperationListener

postDelete

public void postDelete(ShardId shardId,
 Engine.Delete delete,
 Engine.DeleteResult result)

Description copied from interface: IndexingOperationListener

Called after the delete operation occurred. Note that this is also called when deleting a document did not succeed due to document related failures. See IndexingOperationListener.postDelete(ShardId, Engine.Delete, Exception) for engine level failures

Specified by:

postDelete in interface IndexingOperationListener

postDelete

public void postDelete(ShardId shardId,
 Engine.Delete delete,
 Exception ex)

Description copied from interface: IndexingOperationListener

Called after the delete operation occurred with engine level exception. See IndexingOperationListener.postDelete(ShardId, Engine.Delete, Engine.DeleteResult) for document related failures

Specified by:

postDelete in interface IndexingOperationListener