org.elasticsearch.indices.recovery
Class StartRecoveryRequest

java.lang.Object
  org.elasticsearch.indices.recovery.StartRecoveryRequest

All Implemented Interfaces:

Streamable

public class StartRecoveryRequest
extends Object
implements Streamable

Constructor Summary

StartRecoveryRequest(ShardId shardId, DiscoveryNode sourceNode, DiscoveryNode targetNode, boolean markAsRelocated, Map<String,StoreFileMetaData> existingFiles)
Start recovery request.

Method Summary

Map<String,StoreFileMetaData>	existingFiles()
boolean	markAsRelocated()
void	readFrom(StreamInput in)
long	recoveryId()
ShardId	shardId()
DiscoveryNode	sourceNode()
DiscoveryNode	targetNode()
void	writeTo(StreamOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

StartRecoveryRequest

public StartRecoveryRequest(ShardId shardId,
                            DiscoveryNode sourceNode,
                            DiscoveryNode targetNode,
                            boolean markAsRelocated,
                            Map<String,StoreFileMetaData> existingFiles)

Start recovery request.

Parameters:

shardId -

sourceNode - The node to recover from

targetNode - Teh node to recover to

markAsRelocated -

existingFiles -

Method Detail

recoveryId

public long recoveryId()

shardId

public ShardId shardId()

sourceNode

public DiscoveryNode sourceNode()

targetNode

public DiscoveryNode targetNode()

markAsRelocated

public boolean markAsRelocated()

existingFiles

public Map<String,StoreFileMetaData> existingFiles()

readFrom

public void readFrom(StreamInput in)
              throws IOException

Specified by:

readFrom in interface Streamable

Throws:

IOException

writeTo

public void writeTo(StreamOutput out)
             throws IOException

Specified by:

writeTo in interface Streamable

Throws:

IOException