Package org.apache.hadoop.hdfs.server.datanode.erasurecode

Class ErasureCodingWorker

java.lang.Object

org.apache.hadoop.hdfs.server.datanode.erasurecode.ErasureCodingWorker

@Private
public final class ErasureCodingWorker
extends Object

ErasureCodingWorker handles the erasure coding reconstruction work commands. These commands would be issued from Namenode as part of Datanode's heart beat response. BPOfferService delegates the work to this class for handling EC commands.

Constructor Summary

Constructors

Constructor	Description
ErasureCodingWorker(org.apache.hadoop.conf.Configuration conf, DataNode datanode)

Method Summary

Modifier and Type	Method	Description
float	getXmitWeight()
void	processErasureCodingTasks(Collection<BlockECReconstructionCommand.BlockECReconstructionInfo> ecTasks)	Handles the Erasure Coding reconstruction work commands.
void	shutDown()

Methods inherited from class java.lang.Object

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

Constructor Details

ErasureCodingWorker

public ErasureCodingWorker(org.apache.hadoop.conf.Configuration conf,
 DataNode datanode)

Method Details

processErasureCodingTasks

public void processErasureCodingTasks(Collection<BlockECReconstructionCommand.BlockECReconstructionInfo> ecTasks)

Handles the Erasure Coding reconstruction work commands.

Parameters:

ecTasks - BlockECReconstructionInfo

shutDown

public void shutDown()

getXmitWeight

public float getXmitWeight()