alluxio.master.lineage.recompute

Class RecomputeExecutor

java.lang.Object

alluxio.master.lineage.recompute.RecomputeExecutor

All Implemented Interfaces:

HeartbeatExecutor, Closeable, AutoCloseable

@ThreadSafe
public final class RecomputeExecutor
extends Object
implements HeartbeatExecutor

A periodical executor that detects lost files and launches recompute jobs.

Constructor Summary

Constructors

Constructor and Description
RecomputeExecutor(RecomputePlanner planner, FileSystemMaster fileSystemMaster) Creates a new instance of RecomputeExecutor.

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

RecomputeExecutor

public RecomputeExecutor(RecomputePlanner planner,
                         FileSystemMaster fileSystemMaster)

Creates a new instance of RecomputeExecutor.

Parameters:

planner - recompute planner

fileSystemMaster - the file system master

Method Detail

heartbeat

public void heartbeat()

Description copied from interface: HeartbeatExecutor

Implements the heartbeat logic.

Specified by:

heartbeat in interface HeartbeatExecutor

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