alluxio.master.lineage.meta

Class Lineage

java.lang.Object

alluxio.master.lineage.meta.Lineage

All Implemented Interfaces:

JournalEntryRepresentable

@NotThreadSafe
public final class Lineage
extends Object
implements JournalEntryRepresentable

A lineage tracks the dependencies imposed by a job, including the input files the job depends on, and the output files the job generates.

Constructor Summary

Constructors

Constructor and Description
Lineage(long id, List<Long> inputFiles, List<Long> outputFiles, Job job) Creates a new instance of Lineage.
Lineage(long id, List<Long> inputFiles, List<Long> outputFiles, Job job, long creationTimeMs) Creates a new instance of Lineage.

Method Summary

Modifier and Type	Method and Description
static Lineage	fromJournalEntry(Lineage.LineageEntry entry) Converts the entry to a Lineage.
long	getCreationTime()
long	getId()
List<Long>	getInputFiles()
Job	getJob()
List<Long>	getOutputFiles()
Journal.JournalEntry	toJournalEntry()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

Lineage

public Lineage(long id,
               List<Long> inputFiles,
               List<Long> outputFiles,
               Job job)

Creates a new instance of Lineage.

Parameters:

id - the lineage id

inputFiles - the input file ids

outputFiles - the output file ids

job - the job

Lineage

public Lineage(long id,
               List<Long> inputFiles,
               List<Long> outputFiles,
               Job job,
               long creationTimeMs)

Creates a new instance of Lineage. This method should only used by lineage. TODO(yupeng): hide this method

Parameters:

id - the lineage id

inputFiles - the input files

outputFiles - the output files

job - the job

creationTimeMs - the creation time

Method Detail

getInputFiles

public List<Long> getInputFiles()

Returns:

the input file ids

getOutputFiles

public List<Long> getOutputFiles()

Returns:

the output file ids

getJob

public Job getJob()

Returns:

the job

getId

public long getId()

Returns:

the lineage id

getCreationTime

public long getCreationTime()

Returns:

the creation time

fromJournalEntry

public static Lineage fromJournalEntry(Lineage.LineageEntry entry)

Converts the entry to a Lineage.

Parameters:

entry - the entry to convert

Returns:

the Lineage representation

toJournalEntry

public Journal.JournalEntry toJournalEntry()

Specified by:

toJournalEntry in interface JournalEntryRepresentable

Returns:

the Journal.JournalEntry representing this object

toString

public String toString()

Overrides:

toString in class Object