public class LineageState extends Object implements Serializable
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 |
mapDirToOp(org.apache.hadoop.fs.Path dir,
Operator 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.
|
void |
updateDirToOpMap(org.apache.hadoop.fs.Path newPath,
org.apache.hadoop.fs.Path oldPath)
Update the path of the captured lineage information in case the
conditional input path and the linked MoveWork were merged into one MoveWork.
|
public void mapDirToOp(org.apache.hadoop.fs.Path dir, Operator fop)
dir
- The directory name.fop
- The sink operator.public void updateDirToOpMap(org.apache.hadoop.fs.Path newPath, org.apache.hadoop.fs.Path oldPath)
newPath
- conditional input patholdPath
- path of the old linked MoveWorkpublic 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 © 2022 The Apache Software Foundation. All rights reserved.