Package org.apache.hadoop.ozone.protocol.commands

Class ReconstructECContainersCommand

java.lang.Object

org.apache.hadoop.ozone.protocol.commands.SCMCommand<org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.ReconstructECContainersCommandProto>

org.apache.hadoop.ozone.protocol.commands.ReconstructECContainersCommand

All Implemented Interfaces:

org.apache.hadoop.hdds.server.events.IdentifiableEventPayload

public class ReconstructECContainersCommand
extends SCMCommand<org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.ReconstructECContainersCommandProto>

SCM command to request reconstruction of EC containers.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ReconstructECContainersCommand.DatanodeDetailsAndReplicaIndex	To store the datanode details with replica index.

Constructor Summary

Constructors

Constructor	Description
ReconstructECContainersCommand(long containerID, List<ReconstructECContainersCommand.DatanodeDetailsAndReplicaIndex> sources, List<org.apache.hadoop.hdds.protocol.DatanodeDetails> targetDatanodes, com.google.protobuf.ByteString missingContainerIndexes, org.apache.hadoop.hdds.client.ECReplicationConfig ecReplicationConfig)
ReconstructECContainersCommand(long containerID, List<ReconstructECContainersCommand.DatanodeDetailsAndReplicaIndex> sourceDatanodes, List<org.apache.hadoop.hdds.protocol.DatanodeDetails> targetDatanodes, com.google.protobuf.ByteString missingContainerIndexes, org.apache.hadoop.hdds.client.ECReplicationConfig ecReplicationConfig, long id)

Method Summary

Modifier and Type	Method	Description
long	getContainerID()
org.apache.hadoop.hdds.client.ECReplicationConfig	getEcReplicationConfig()
static ReconstructECContainersCommand	getFromProtobuf(org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.ReconstructECContainersCommandProto protoMessage)
com.google.protobuf.ByteString	getMissingContainerIndexes()
org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.ReconstructECContainersCommandProto	getProto()	Gets the protobuf message of this object.
List<ReconstructECContainersCommand.DatanodeDetailsAndReplicaIndex>	getSources()
List<org.apache.hadoop.hdds.protocol.DatanodeDetails>	getTargetDatanodes()
org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMCommandProto.Type	getType()	Returns the type of this command.
String	toString()

Methods inherited from class org.apache.hadoop.ozone.protocol.commands.SCMCommand

contributesToQueueSize, getDeadline, getEncodedToken, getId, getTerm, hasExpired, setDeadline, setEncodedToken, setTerm

Methods inherited from class java.lang.Object

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

Constructor Details

ReconstructECContainersCommand

public ReconstructECContainersCommand(long containerID,
 List<ReconstructECContainersCommand.DatanodeDetailsAndReplicaIndex> sources,
 List<org.apache.hadoop.hdds.protocol.DatanodeDetails> targetDatanodes,
 com.google.protobuf.ByteString missingContainerIndexes,
 org.apache.hadoop.hdds.client.ECReplicationConfig ecReplicationConfig)

ReconstructECContainersCommand

public ReconstructECContainersCommand(long containerID,
 List<ReconstructECContainersCommand.DatanodeDetailsAndReplicaIndex> sourceDatanodes,
 List<org.apache.hadoop.hdds.protocol.DatanodeDetails> targetDatanodes,
 com.google.protobuf.ByteString missingContainerIndexes,
 org.apache.hadoop.hdds.client.ECReplicationConfig ecReplicationConfig,
 long id)

Method Details

getType

public org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMCommandProto.Type getType()

Description copied from class: SCMCommand

Returns the type of this command.

Specified by:

getType in class SCMCommand<org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.ReconstructECContainersCommandProto>

Returns:

Type

getProto

public org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.ReconstructECContainersCommandProto getProto()

Description copied from class: SCMCommand

Gets the protobuf message of this object.

Specified by:

getProto in class SCMCommand<org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.ReconstructECContainersCommandProto>

Returns:

A protobuf message.

getFromProtobuf

public static ReconstructECContainersCommand getFromProtobuf(org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.ReconstructECContainersCommandProto protoMessage)

getContainerID

public long getContainerID()

getSources

public List<ReconstructECContainersCommand.DatanodeDetailsAndReplicaIndex> getSources()

getTargetDatanodes

public List<org.apache.hadoop.hdds.protocol.DatanodeDetails> getTargetDatanodes()

getMissingContainerIndexes

public com.google.protobuf.ByteString getMissingContainerIndexes()

getEcReplicationConfig

public org.apache.hadoop.hdds.client.ECReplicationConfig getEcReplicationConfig()

toString

public String toString()

Overrides:

toString in class SCMCommand<org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.ReconstructECContainersCommandProto>