alluxio.master.lineage.meta

Class LineageStateUtils

java.lang.Object

alluxio.master.lineage.meta.LineageStateUtils

@ThreadSafe
public final class LineageStateUtils
extends Object

Utility methods for checking the state of lineage files.

Method Summary

Modifier and Type	Method and Description
static List<Long>	getLostFiles(Lineage lineage, FileSystemMasterView fileSystemMasterView)
static boolean	isCompleted(Lineage lineage, FileSystemMasterView fileSystemMasterView) Checks if all the output files of the given lineage are completed.
static boolean	isInCheckpointing(Lineage lineage, FileSystemMasterView fileSystemMasterView)
static boolean	isPersisted(Lineage lineage, FileSystemMasterView fileSystemMasterView)
static boolean	needRecompute(Lineage lineage, FileSystemMasterView fileSystemMasterView)

Methods inherited from class java.lang.Object

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

Method Detail

isCompleted

public static boolean isCompleted(Lineage lineage,
                                  FileSystemMasterView fileSystemMasterView)
                           throws FileDoesNotExistException,
                                  AccessControlException,
                                  UnavailableException

Checks if all the output files of the given lineage are completed.

Parameters:

lineage - the lineage to check

fileSystemMasterView - the view of the file system master where the output file lies

Returns:

true if all the output files of the given lineage are completed, false otherwise

Throws:

FileDoesNotExistException - if the file does not exist

AccessControlException - if permission denied

UnavailableException

needRecompute

public static boolean needRecompute(Lineage lineage,
                                    FileSystemMasterView fileSystemMasterView)
                             throws FileDoesNotExistException

Parameters:

lineage - the lineage to check

fileSystemMasterView - the view of the file system master

Returns:

true if the lineage needs recompute, false otherwise

Throws:

FileDoesNotExistException - if any output file of the lineage does not exist

isPersisted

public static boolean isPersisted(Lineage lineage,
                                  FileSystemMasterView fileSystemMasterView)
                           throws FileDoesNotExistException

Parameters:

lineage - the lineage to check

fileSystemMasterView - the view of the file system master

Returns:

true if all the output files are persisted, false otherwise

Throws:

FileDoesNotExistException - if the file does not exist

isInCheckpointing

public static boolean isInCheckpointing(Lineage lineage,
                                        FileSystemMasterView fileSystemMasterView)
                                 throws FileDoesNotExistException

Parameters:

lineage - the lineage to check

fileSystemMasterView - the view of the file system master

Returns:

true if at least one of the output files is being persisted, false otherwise

Throws:

FileDoesNotExistException - if the file does not exist

getLostFiles

public static List<Long> getLostFiles(Lineage lineage,
                                      FileSystemMasterView fileSystemMasterView)
                               throws FileDoesNotExistException

Parameters:

lineage - the lineage to check

fileSystemMasterView - the view of the file system master

Returns:

all the output files of the given lineage that are lost on the workers

Throws:

FileDoesNotExistException - if any output file of the lineage does not exist