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

Constructors

Constructor and Description
LineageState() Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
void	clear() Clear all lineage states
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<FieldSchema> cols) Set the lineage information for the associated directory.

Methods inherited from class java.lang.Object

clone, equals, finalize, 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<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.

clear

public void clear()

Clear all lineage states