org.apache.hadoop.hive.ql.hooks

Class LineageInfo

java.lang.Object

org.apache.hadoop.hive.ql.hooks.LineageInfo

All Implemented Interfaces:

Serializable

public class LineageInfo
extends Object
implements Serializable

This class contains the lineage information that is passed to the PreExecution hook.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LineageInfo.BaseColumnInfo Base Column information.
static class	LineageInfo.DataContainer Table or Partition data container.
static class	LineageInfo.Dependency This class tracks the dependency information for the base column.
static class	LineageInfo.DependencyKey Class that captures the lookup key for the dependency.
static class	LineageInfo.DependencyType Enum to track dependency.
static class	LineageInfo.Predicate This class tracks the predicate information for an operator.
static class	LineageInfo.TableAliasInfo

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<LineageInfo.DependencyKey,LineageInfo.Dependency>	index The map contains an index from the (datacontainer, columnname) to the dependency vector for that tuple.

Constructor Summary

Constructors

Constructor and Description
LineageInfo() Constructor.

Method Summary

Modifier and Type	Method and Description
void	clear()
Set<Map.Entry<LineageInfo.DependencyKey,LineageInfo.Dependency>>	entrySet() Gets the entry set on this structure.
LineageInfo.Dependency	getDependency(LineageInfo.DataContainer dc, org.apache.hadoop.hive.metastore.api.FieldSchema col) Gets the dependency for a table, column tuple.
void	putDependency(LineageInfo.DataContainer dc, org.apache.hadoop.hive.metastore.api.FieldSchema col, LineageInfo.Dependency dep) Puts the dependency for a table, column tuple.

Methods inherited from class java.lang.Object

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

Field Detail

index

protected Map<LineageInfo.DependencyKey,LineageInfo.Dependency> index

The map contains an index from the (datacontainer, columnname) to the dependency vector for that tuple. This is used to generate the dependency vectors during the walk of the operator tree.

Constructor Detail

LineageInfo

public LineageInfo()

Constructor.

Method Detail

getDependency

public LineageInfo.Dependency getDependency(LineageInfo.DataContainer dc,
                                            org.apache.hadoop.hive.metastore.api.FieldSchema col)

Gets the dependency for a table, column tuple.

Parameters:

dc - The data container of the column whose dependency is being inspected.

col - The column whose dependency is being inspected.

Returns:

Dependency for that particular table, column tuple. null if no dependency is found.

putDependency

public void putDependency(LineageInfo.DataContainer dc,
                          org.apache.hadoop.hive.metastore.api.FieldSchema col,
                          LineageInfo.Dependency dep)

Puts the dependency for a table, column tuple.

Parameters:

dc - The datacontainer whose dependency is being inserted.

col - The column whose dependency is being inserted.

dep - The dependency.

entrySet

public Set<Map.Entry<LineageInfo.DependencyKey,LineageInfo.Dependency>> entrySet()

Gets the entry set on this structure.

Returns:

LineageInfo entry set

clear

public void clear()