@PublicApi public abstract class AbstractLineageClient extends Object
Modifier and Type | Field and Description |
---|---|
protected LineageContext |
mContext |
Constructor and Description |
---|
AbstractLineageClient() |
Modifier and Type | Method and Description |
---|---|
long |
createLineage(List<TachyonURI> inputFiles,
List<TachyonURI> outputFiles,
Job job,
CreateLineageOptions options)
Creates a lineage.
|
boolean |
deleteLineage(long lineageId,
DeleteLineageOptions options)
Deletes a lineage identified by a given id.
|
List<LineageInfo> |
getLineageInfoList(GetLineageInfoListOptions options)
Lists all the lineages.
|
protected LineageContext mContext
public long createLineage(List<TachyonURI> inputFiles, List<TachyonURI> outputFiles, Job job, CreateLineageOptions options) throws FileDoesNotExistException, TachyonException, IOException
inputFiles
- the files that the job depends onoutputFiles
- the files that the job outputsjob
- the job that takes the listed input file and computes the output fileoptions
- the method optionsFileDoesNotExistException
- an input file does not exist in Tachyon storage, nor is added
as an output file of an existing lineageTachyonException
- if an unexpected tachyon error occursIOException
- if the master cannot create the lineagepublic boolean deleteLineage(long lineageId, DeleteLineageOptions options) throws IOException, LineageDoesNotExistException, LineageDeletionException, TachyonException
lineageId
- the id of the lineageoptions
- method optionsIOException
- if the master cannot delete the lineageLineageDoesNotExistException
- if the lineage does not existLineageDeletionException
- if the deletion is cascade but the lineage has childrenTachyonException
- if an unexpected tachyon error occurspublic List<LineageInfo> getLineageInfoList(GetLineageInfoListOptions options) throws IOException
options
- method optionsIOException
- if the master cannot list the lineage infoCopyright © 2015. All Rights Reserved.