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

Class ReplicateContainerCommand

java.lang.Object
org.apache.hadoop.ozone.protocol.commands.SCMCommand<org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.ReplicateContainerCommandProto>
org.apache.hadoop.ozone.protocol.commands.ReplicateContainerCommand
All Implemented Interfaces:
org.apache.hadoop.hdds.server.events.IdentifiableEventPayload
public final class ReplicateContainerCommand extends SCMCommand<org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.ReplicateContainerCommandProto>
SCM command to request replication of a container.

  • Method Details

    • fromSources

      public static ReplicateContainerCommand fromSources(long containerID, List<org.apache.hadoop.hdds.protocol.DatanodeDetails> sourceDatanodes)

    • toTarget

      public static ReplicateContainerCommand toTarget(long containerID, org.apache.hadoop.hdds.protocol.DatanodeDetails target)

    • forTest

      public static ReplicateContainerCommand forTest(long containerID)

    • setReplicaIndex

      public void setReplicaIndex(int index)

    • setPriority

      public void setPriority(org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.ReplicationCommandPriority priority)

    • 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.ReplicateContainerCommandProto>
      Returns:
      Type

    • contributesToQueueSize

      public boolean contributesToQueueSize()
      Overrides:
      contributesToQueueSize in class SCMCommand<org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.ReplicateContainerCommandProto>

    • getProto

      public org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.ReplicateContainerCommandProto 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.ReplicateContainerCommandProto>
      Returns:
      A protobuf message.

    • getFromProtobuf

      public static ReplicateContainerCommand getFromProtobuf(org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.ReplicateContainerCommandProto protoMessage)

    • getContainerID

      public long getContainerID()

    • getSourceDatanodes

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

    • getTargetDatanode

      public org.apache.hadoop.hdds.protocol.DatanodeDetails getTargetDatanode()

    • getReplicaIndex

      public int getReplicaIndex()

    • getPriority

      public org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.ReplicationCommandPriority getPriority()

    • toString

      public String toString()
      Overrides:
      toString in class SCMCommand<org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.ReplicateContainerCommandProto>