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

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.TableAliasInfo

Field Summary

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

LineageInfo()
Constructor.

Method Summary

Set<Map.Entry<LineageInfo.DependencyKey,LineageInfo.Dependency>>	entrySet() Gets the entry set on this structure.
LineageInfo.Dependency	getDependency(LineageInfo.DataContainer dc, FieldSchema col) Gets the dependency for a table, column tuple.
void	putDependency(LineageInfo.DataContainer dc, 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,
                                            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,
                          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