public class LineageState
extends java.lang.Object
Constructor and Description |
---|
LineageState()
Constructor.
|
Modifier and Type | Method and Description |
---|---|
LineageInfo |
getLineageInfo()
Gets the lineage information.
|
void |
mapDirToFop(java.lang.String dir,
FileSinkOperator fop)
Adds a mapping from the load work to the file sink operator.
|
void |
setIndex(LineageCtx.Index index)
Sets the index for the lineage state.
|
void |
setLineage(java.lang.String dir,
LineageInfo.DataContainer dc,
java.util.List<FieldSchema> cols)
Set the lineage information for the associated directory.
|
public void mapDirToFop(java.lang.String dir, FileSinkOperator fop)
dir
- The directory name.fop
- The file sink operator.public void setLineage(java.lang.String dir, LineageInfo.DataContainer dc, java.util.List<FieldSchema> cols)
dir
- The directory containing the query results.dc
- The associated data container.cols
- The list of columns.public LineageInfo getLineageInfo()
public void setIndex(LineageCtx.Index index)
index
- The index derived from lineage context.Copyright © 2012 The Apache Software Foundation