alluxio.master.file.replication

Class ReplicationChecker

java.lang.Object

alluxio.master.file.replication.ReplicationChecker

All Implemented Interfaces:

HeartbeatExecutor, java.io.Closeable, java.lang.AutoCloseable

@ThreadSafe
public final class ReplicationChecker
extends java.lang.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()
void	heartbeat() During this heartbeat, this class will check:

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 java.lang.InterruptedException

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:

java.lang.InterruptedException

close

public void close()

Specified by:

close in interface HeartbeatExecutor

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable