alluxio.master.journal

Class CatchupFuture

java.lang.Object

alluxio.master.journal.CatchupFuture

public class CatchupFuture
extends Object

Used to track and cancel journal advancing.

Constructor Summary

Constructors

Constructor and Description
CatchupFuture(AbstractCatchupThread catchupThread) Creates a tracker for given catchup thread.

Method Summary

Modifier and Type	Method and Description
static CatchupFuture	allOf(List<CatchupFuture> futures) Creates a single future for tracking a list of catchup futures.
void	cancel() Cancels catchup progress gracefully.
static CatchupFuture	completed()
void	waitTermination() Waits until advancing finishes.

Methods inherited from class java.lang.Object

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

Constructor Detail

CatchupFuture

public CatchupFuture(AbstractCatchupThread catchupThread)

Creates a tracker for given catchup thread.

Parameters:

catchupThread - journal catchup thread

Method Detail

allOf

public static CatchupFuture allOf(List<CatchupFuture> futures)

Creates a single future for tracking a list of catchup futures.

Parameters:

futures - list of catchup futures

Returns:

unified catchup future

completed

public static CatchupFuture completed()

Returns:

a completed catchup future

cancel

public void cancel()

Cancels catchup progress gracefully.

waitTermination

public void waitTermination()

Waits until advancing finishes.