Package org.apache.hadoop.ozone.container.replication

Class ReplicationTask

java.lang.Object

org.apache.hadoop.ozone.container.replication.AbstractReplicationTask

org.apache.hadoop.ozone.container.replication.ReplicationTask

public class ReplicationTask
extends AbstractReplicationTask

The task to download a container from the sources.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.ozone.container.replication.AbstractReplicationTask

AbstractReplicationTask.Status

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ReplicationTask(long containerId, List<org.apache.hadoop.hdds.protocol.DatanodeDetails> sources, ContainerReplicator replicator)	Intended to only be used in tests.
	ReplicationTask(ReplicateContainerCommand cmd, ContainerReplicator replicator)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
protected Object	getCommandForDebug()	Hook for subclasses to provide info about the command.
long	getContainerId()
String	getMetricDescriptionSegment()
String	getMetricName()
List<org.apache.hadoop.hdds.protocol.DatanodeDetails>	getSources()
long	getTransferredBytes()
int	hashCode()
void	runTask()	Abstract method which needs to be overridden by the sub classes to execute the task.
void	setTransferredBytes(long transferredBytes)
String	toString()

Methods inherited from class org.apache.hadoop.ozone.container.replication.AbstractReplicationTask

getDeadline, getPriority, getQueued, getStatus, getTerm, setPriority, setShouldOnlyRunOnInServiceDatanodes, setStatus, shouldOnlyRunOnInServiceDatanodes

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

ReplicationTask

public ReplicationTask(ReplicateContainerCommand cmd,
 ContainerReplicator replicator)

ReplicationTask

protected ReplicationTask(long containerId,
 List<org.apache.hadoop.hdds.protocol.DatanodeDetails> sources,
 ContainerReplicator replicator)

Intended to only be used in tests.

Method Details

getMetricName

public String getMetricName()

Specified by:

getMetricName in class AbstractReplicationTask

getMetricDescriptionSegment

public String getMetricDescriptionSegment()

Specified by:

getMetricDescriptionSegment in class AbstractReplicationTask

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

getContainerId

public long getContainerId()

Overrides:

getContainerId in class AbstractReplicationTask

getSources

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

getCommandForDebug

protected Object getCommandForDebug()

Description copied from class: AbstractReplicationTask

Hook for subclasses to provide info about the command.

Overrides:

getCommandForDebug in class AbstractReplicationTask

Returns:

string representation of the command

toString

public String toString()

Overrides:

toString in class AbstractReplicationTask

getTransferredBytes

public long getTransferredBytes()

setTransferredBytes

public void setTransferredBytes(long transferredBytes)

runTask

public void runTask()

Description copied from class: AbstractReplicationTask

Abstract method which needs to be overridden by the sub classes to execute the task.

Specified by:

runTask in class AbstractReplicationTask