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

Class ReplicationSupervisor.TaskRunner

java.lang.Object

org.apache.hadoop.ozone.container.replication.ReplicationSupervisor.TaskRunner

All Implemented Interfaces:

Comparable<ReplicationSupervisor.TaskRunner>, Runnable

Enclosing class:

ReplicationSupervisor

public final class ReplicationSupervisor.TaskRunner
extends Object
implements Comparable<ReplicationSupervisor.TaskRunner>, Runnable

An executable form of a replication task with status handling.

Constructor Summary

Constructors

Constructor	Description
TaskRunner(AbstractReplicationTask task)

Method Summary

Modifier and Type	Method	Description
int	compareTo(ReplicationSupervisor.TaskRunner o)
boolean	equals(Object o)
org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.ReplicationCommandPriority	getTaskPriority()
long	getTaskQueueTime()
int	hashCode()
void	run()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

TaskRunner

public TaskRunner(AbstractReplicationTask task)

Method Details

run

public void run()

Specified by:

run in interface Runnable

toString

public String toString()

Overrides:

toString in class Object

getTaskPriority

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

getTaskQueueTime

public long getTaskQueueTime()

compareTo

public int compareTo(ReplicationSupervisor.TaskRunner o)

Specified by:

compareTo in interface Comparable<ReplicationSupervisor.TaskRunner>

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object