org.apache.hadoop.hive.ql.session

Class LineageState

java.lang.Object

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

All Implemented Interfaces:

Serializable

public class LineageState
extends Object
implements Serializable

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

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
LineageState() Constructor.

Method Summary

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<org.apache.hadoop.hive.metastore.api.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.

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

mapDirToOp

public void mapDirToOp(org.apache.hadoop.fs.Path dir,
                       Operator fop)

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

Parameters:

dir - The directory name.

fop - The sink operator.

updateDirToOpMap

public 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. This should only happen for Blobstore systems with optimization turned on.

Parameters:

newPath - conditional input path

oldPath - path of the old linked MoveWork

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.

getIndex

public LineageCtx.Index getIndex()

Gets the index for the lineage state.

Returns:

Index.

clear

public void clear()

Clear all lineage states