public class LineageState extends Object
Constructor and Description |
---|
LineageState()
Constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
clear()
Clear all lineage states
|
LineageCtx.Index |
getIndex()
Gets the index for the lineage state.
|
LineageInfo |
getLineageInfo()
Gets the lineage information.
|
void |
mapDirToFop(org.apache.hadoop.fs.Path dir,
FileSinkOperator fop)
Adds a mapping from the load work to the file sink operator.
|
void |
setLineage(org.apache.hadoop.fs.Path dir,
LineageInfo.DataContainer dc,
List<FieldSchema> cols)
Set the lineage information for the associated directory.
|
public void mapDirToFop(org.apache.hadoop.fs.Path dir, FileSinkOperator fop)
dir
- The directory name.fop
- The file sink operator.public void setLineage(org.apache.hadoop.fs.Path dir, LineageInfo.DataContainer dc, List<FieldSchema> cols)
dir
- The directory containing the query results.dc
- The associated data container.cols
- The list of columns.public LineageInfo getLineageInfo()
public LineageCtx.Index getIndex()
public void clear()
Copyright © 2016 The Apache Software Foundation. All rights reserved.