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

Class BlockStorageMovementTracker

java.lang.Object

org.apache.hadoop.hdfs.server.common.sps.BlockStorageMovementTracker

All Implemented Interfaces:

Runnable

@Private
@Evolving
public class BlockStorageMovementTracker
extends Object
implements Runnable

This class is used to track the completion of block movement future tasks.

Constructor Summary

Constructors

Constructor	Description
BlockStorageMovementTracker(CompletionService<BlockMovementAttemptFinished> moverCompletionService, BlocksMovementsStatusHandler handler)	BlockStorageMovementTracker constructor.

Method Summary

Modifier and Type	Method	Description
void	run()
void	stopTracking()	Sets running flag to false.

Methods inherited from class java.lang.Object

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

Constructor Details

BlockStorageMovementTracker

public BlockStorageMovementTracker(CompletionService<BlockMovementAttemptFinished> moverCompletionService,
 BlocksMovementsStatusHandler handler)

BlockStorageMovementTracker constructor.

Parameters:

moverCompletionService - completion service.

handler - blocks movements status handler

Method Details

run

public void run()

Specified by:

run in interface Runnable

stopTracking

public void stopTracking()

Sets running flag to false.