Package org.apache.hadoop.ozone.container.ec.reconstruction

Class ECReconstructionCoordinatorTask

java.lang.Object

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

org.apache.hadoop.ozone.container.ec.reconstruction.ECReconstructionCoordinatorTask

All Implemented Interfaces:

Runnable

public class ECReconstructionCoordinatorTask
extends AbstractReplicationTask
implements Runnable

This is the actual EC reconstruction coordination task.

Nested Class Summary

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

AbstractReplicationTask.Status

Constructor Summary

Constructors

Constructor	Description
ECReconstructionCoordinatorTask(ECReconstructionCoordinator coordinator, ECReconstructionCommandInfo reconstructionCommandInfo)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
protected Object	getCommandForDebug()	Hook for subclasses to provide info about the command.
String	getMetricDescriptionSegment()
String	getMetricName()
int	hashCode()
void	run()
void	runTask()	Abstract method which needs to be overridden by the sub classes to execute the task.

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

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

Methods inherited from class java.lang.Object

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

Constructor Details

ECReconstructionCoordinatorTask

public ECReconstructionCoordinatorTask(ECReconstructionCoordinator coordinator,
 ECReconstructionCommandInfo reconstructionCommandInfo)

Method Details

getMetricName

public String getMetricName()

Specified by:

getMetricName in class AbstractReplicationTask

getMetricDescriptionSegment

public String getMetricDescriptionSegment()

Specified by:

getMetricDescriptionSegment in class AbstractReplicationTask

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

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

run

public void run()

Specified by:

run in interface Runnable

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object