org.elasticsearch.indices.recovery

Class SharedFSRecoverySourceHandler

java.lang.Object

org.elasticsearch.indices.recovery.RecoverySourceHandler

org.elasticsearch.indices.recovery.SharedFSRecoverySourceHandler

public class SharedFSRecoverySourceHandler
extends RecoverySourceHandler

A recovery handler that skips phase 1 as well as sending the snapshot. During phase 3 the shard is marked as relocated an closed to ensure that the engine is closed and the target can acquire the IW write lock.

Field Summary

Fields inherited from class org.elasticsearch.indices.recovery.RecoverySourceHandler

logger, response

Constructor Summary

Constructors

Constructor and Description
SharedFSRecoverySourceHandler(IndexShard shard, RecoveryTargetHandler recoveryTarget, StartRecoveryRequest request, java.util.function.Supplier<java.lang.Long> currentClusterStateVersionSupplier, java.util.function.Function<java.lang.String,Releasable> delayNewRecoveries, org.apache.logging.log4j.Logger logger)

Method Summary

Modifier and Type	Method and Description
org.elasticsearch.indices.recovery.RecoveryResponse	recoverToTarget() performs the recovery from the local engine to the target
protected int	sendSnapshot(Translog.Snapshot snapshot) Send the given snapshot's operations to this handler's target node.

Methods inherited from class org.elasticsearch.indices.recovery.RecoverySourceHandler

cancel, failEngine, finalizeRecovery, phase1, phase2, prepareTargetForTranslog, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

SharedFSRecoverySourceHandler

public SharedFSRecoverySourceHandler(IndexShard shard,
                                     RecoveryTargetHandler recoveryTarget,
                                     StartRecoveryRequest request,
                                     java.util.function.Supplier<java.lang.Long> currentClusterStateVersionSupplier,
                                     java.util.function.Function<java.lang.String,Releasable> delayNewRecoveries,
                                     org.apache.logging.log4j.Logger logger)

Method Detail

recoverToTarget

public org.elasticsearch.indices.recovery.RecoveryResponse recoverToTarget()
                                                                    throws java.io.IOException

Description copied from class: RecoverySourceHandler

performs the recovery from the local engine to the target

Overrides:

recoverToTarget in class RecoverySourceHandler

Throws:

java.io.IOException

sendSnapshot

protected int sendSnapshot(Translog.Snapshot snapshot)

Description copied from class: RecoverySourceHandler

Send the given snapshot's operations to this handler's target node.

Operations are bulked into a single request depending on an operation count limit or size-in-bytes limit

Overrides:

sendSnapshot in class RecoverySourceHandler

Returns:

the total number of translog operations that were sent