alluxio.master.file.replication

Class ReplicationChecker

java.lang.Object

alluxio.master.file.replication.ReplicationChecker

All Implemented Interfaces:

HeartbeatExecutor, Closeable, AutoCloseable

@ThreadSafe
public final class ReplicationChecker
extends Object
implements HeartbeatExecutor

The executor to check block replication level periodically and handle over-replicated and under-replicated blocks correspondingly.

Constructor Summary

Constructors

Constructor and Description
ReplicationChecker(InodeTree inodeTree, BlockMaster blockMaster, SafeModeManager safeModeManager, JobMasterClientPool jobMasterClientPool) Constructs a new ReplicationChecker using default (job service) handler to replicate and evict blocks.
ReplicationChecker(InodeTree inodeTree, BlockMaster blockMaster, SafeModeManager safeModeManager, ReplicationHandler replicationHandler) Constructs a new ReplicationChecker with specified replicate and evict handlers (for unit testing).

Method Summary

Modifier and Type	Method and Description
void	close() Cleans up any resources used by the heartbeat executor.
void	heartbeat() Implements the heartbeat logic.

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationChecker

public ReplicationChecker(InodeTree inodeTree,
                          BlockMaster blockMaster,
                          SafeModeManager safeModeManager,
                          JobMasterClientPool jobMasterClientPool)

Constructs a new ReplicationChecker using default (job service) handler to replicate and evict blocks.

Parameters:

inodeTree - inode tree of the filesystem master

blockMaster - block master

safeModeManager - manager of master safe mode state

jobMasterClientPool - job master client pool

ReplicationChecker

public ReplicationChecker(InodeTree inodeTree,
                          BlockMaster blockMaster,
                          SafeModeManager safeModeManager,
                          ReplicationHandler replicationHandler)

Constructs a new ReplicationChecker with specified replicate and evict handlers (for unit testing).

Parameters:

inodeTree - inode tree of the filesystem master

blockMaster - block master

safeModeManager - manager of master safe mode state

replicationHandler - handler to replicate blocks

Method Detail

heartbeat

public void heartbeat()
               throws InterruptedException

Implements the heartbeat logic. During this heartbeat, this class will check:

(1) Is there any block from the pinned files becomes under replicated (i.e., the number of existing copies is smaller than the target replication min for this file, possibly due to node failures), and schedule replicate jobs to increase the replication level when found; (2) Is there any blocks over replicated, schedule evict jobs to reduce the replication level.

Specified by:

heartbeat in interface HeartbeatExecutor

Throws:

InterruptedException - if the thread is interrupted

close

public void close()

Description copied from interface: HeartbeatExecutor

Cleans up any resources used by the heartbeat executor.

Specified by:

close in interface HeartbeatExecutor

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable