org.elasticsearch.index.shard

Class TranslogRecoveryPerformer

java.lang.Object

org.elasticsearch.index.shard.TranslogRecoveryPerformer

public class TranslogRecoveryPerformer
extends java.lang.Object

The TranslogRecoveryPerformer encapsulates all the logic needed to transform a translog entry into an indexing operation including source parsing and field creation from the source.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TranslogRecoveryPerformer.BatchOperationException

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TranslogRecoveryPerformer(ShardId shardId, MapperService mapperService, org.apache.logging.log4j.Logger logger)

Method Summary

Modifier and Type	Method and Description
protected void	delete(Engine engine, Engine.Delete engineDelete)
protected DocumentMapperForType	docMapper(java.lang.String type)
java.util.Map<java.lang.String,Mapping>	getRecoveredTypes() Returns the recovered types modifying the mapping during the recovery
protected void	index(Engine engine, Engine.Index engineIndex)
protected void	operationProcessed() Called once for every processed operation by this recovery performer.
int	recoveryFromSnapshot(Engine engine, Translog.Snapshot snapshot)

Methods inherited from class java.lang.Object

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

Constructor Detail

TranslogRecoveryPerformer

protected TranslogRecoveryPerformer(ShardId shardId,
                                    MapperService mapperService,
                                    org.apache.logging.log4j.Logger logger)

Method Detail

docMapper

protected DocumentMapperForType docMapper(java.lang.String type)

recoveryFromSnapshot

public int recoveryFromSnapshot(Engine engine,
                                Translog.Snapshot snapshot)
                         throws java.io.IOException

Throws:

java.io.IOException

index

protected void index(Engine engine,
                     Engine.Index engineIndex)
              throws java.io.IOException

Throws:

java.io.IOException

delete

protected void delete(Engine engine,
                      Engine.Delete engineDelete)
               throws java.io.IOException

Throws:

java.io.IOException

operationProcessed

protected void operationProcessed()

Called once for every processed operation by this recovery performer. This can be used to get progress information on the translog execution.

getRecoveredTypes

public java.util.Map<java.lang.String,Mapping> getRecoveredTypes()

Returns the recovered types modifying the mapping during the recovery