org.apache.hadoop.hive.ql.session
Class LineageState

java.lang.Object
  org.apache.hadoop.hive.ql.session.LineageState

public class LineageState
extends Object

LineageState. Contains all the information used to generate the lineage information for the post execution hooks.

Constructor Summary

LineageState()
Constructor.

Method Summary

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	setIndex(LineageCtx.Index index) Sets the index for the lineage state.
void	setLineage(org.apache.hadoop.fs.Path dir, LineageInfo.DataContainer dc, List<org.apache.hadoop.hive.metastore.api.FieldSchema> cols) Set the lineage information for the associated directory.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LineageState

public LineageState()

Constructor.

Method Detail

mapDirToFop

public void mapDirToFop(org.apache.hadoop.fs.Path dir,
                        FileSinkOperator fop)

Adds a mapping from the load work to the file sink operator.

Parameters:

dir - The directory name.

fop - The file sink operator.

setLineage

public void setLineage(org.apache.hadoop.fs.Path dir,
                       LineageInfo.DataContainer dc,
                       List<org.apache.hadoop.hive.metastore.api.FieldSchema> cols)

Set the lineage information for the associated directory.

Parameters:

dir - The directory containing the query results.

dc - The associated data container.

cols - The list of columns.

getLineageInfo

public LineageInfo getLineageInfo()

Gets the lineage information.

Returns:

LineageInfo.

setIndex

public void setIndex(LineageCtx.Index index)

Sets the index for the lineage state.

Parameters:

index - The index derived from lineage context.