Package org.apache.hadoop.hdfs.server.sps

Class ExternalSPSBlockMoveTaskHandler

java.lang.Object

org.apache.hadoop.hdfs.server.sps.ExternalSPSBlockMoveTaskHandler

All Implemented Interfaces:

BlockMoveTaskHandler

@Private
@Evolving
public class ExternalSPSBlockMoveTaskHandler
extends Object
implements BlockMoveTaskHandler

This class handles the external SPS block movements. This will move the given block to a target datanode by directly establishing socket connection to it and invokes function Sender.replaceBlock(ExtendedBlock, StorageType, Token, String, DatanodeInfo, String).

Constructor Summary

Constructors

Constructor	Description
ExternalSPSBlockMoveTaskHandler(org.apache.hadoop.conf.Configuration conf, NameNodeConnector nnc, SPSService spsService)

Method Summary

Modifier and Type	Method	Description
void	submitMoveTask(BlockStorageMovementCommand.BlockMovingInfo blkMovingInfo)	This is an interface method to handle the move tasks.

Methods inherited from class java.lang.Object

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

Constructor Details

ExternalSPSBlockMoveTaskHandler

public ExternalSPSBlockMoveTaskHandler(org.apache.hadoop.conf.Configuration conf,
 NameNodeConnector nnc,
 SPSService spsService)

Method Details

submitMoveTask

public void submitMoveTask(BlockStorageMovementCommand.BlockMovingInfo blkMovingInfo)
                    throws IOException

Description copied from interface: BlockMoveTaskHandler

This is an interface method to handle the move tasks. BlockMovingInfo must contain the required info to move the block, that source location, destination location and storage types.

Specified by:

submitMoveTask in interface BlockMoveTaskHandler

Throws:

IOException