public class StartRecoveryRequest extends TransportRequest
TransportRequest.Empty
Constructor and Description |
---|
StartRecoveryRequest(ShardId shardId,
DiscoveryNode sourceNode,
DiscoveryNode targetNode,
boolean markAsRelocated,
Map<String,StoreFileMetaData> existingFiles,
RecoveryState.Type recoveryType,
long recoveryId)
Start recovery request.
|
Modifier and Type | Method and Description |
---|---|
Map<String,StoreFileMetaData> |
existingFiles() |
boolean |
markAsRelocated() |
void |
readFrom(StreamInput in) |
long |
recoveryId() |
RecoveryState.Type |
recoveryType() |
ShardId |
shardId() |
DiscoveryNode |
sourceNode() |
DiscoveryNode |
targetNode() |
void |
writeTo(StreamOutput out) |
getHeader, getHeaders, hasHeader, putHeader, remoteAddress, remoteAddress
contextSize, copyContextFrom, getContext, getFromContext, getFromContext, hasInContext, isContextEmpty, putAllInContext, putInContext
public StartRecoveryRequest(ShardId shardId, DiscoveryNode sourceNode, DiscoveryNode targetNode, boolean markAsRelocated, Map<String,StoreFileMetaData> existingFiles, RecoveryState.Type recoveryType, long recoveryId)
shardId
- sourceNode
- The node to recover fromtargetNode
- The node to recover tomarkAsRelocated
- existingFiles
- public long recoveryId()
public ShardId shardId()
public DiscoveryNode sourceNode()
public DiscoveryNode targetNode()
public boolean markAsRelocated()
public Map<String,StoreFileMetaData> existingFiles()
public RecoveryState.Type recoveryType()
public void readFrom(StreamInput in) throws IOException
readFrom
in interface Streamable
readFrom
in class TransportMessage<TransportRequest>
IOException
public void writeTo(StreamOutput out) throws IOException
writeTo
in interface Streamable
writeTo
in class TransportMessage<TransportRequest>
IOException
Copyright © 2009–2015. All rights reserved.