org.apache.hadoop.hive.ql.optimizer.lineage
Class LineageCtx.Index

java.lang.Object
  org.apache.hadoop.hive.ql.optimizer.lineage.LineageCtx.Index

Enclosing class:

LineageCtx

public static class LineageCtx.Index
extends Object

Constructor Summary

LineageCtx.Index()
Constructor.

Method Summary

void	clear()
LineageInfo.Dependency	getDependency(Operator<? extends OperatorDesc> op, ColumnInfo col) Gets the dependency for an operator, columninfo tuple.
void	mergeDependency(Operator<? extends OperatorDesc> op, ColumnInfo ci, LineageInfo.Dependency dep) Merges the new dependencies in dep to the existing dependencies of (op, ci).
void	putDependency(Operator<? extends OperatorDesc> op, ColumnInfo col, LineageInfo.Dependency dep) Puts the dependency for an operator, columninfo tuple.

Methods inherited from class java.lang.Object

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

Constructor Detail

LineageCtx.Index

public LineageCtx.Index()

Constructor.

Method Detail

getDependency

public LineageInfo.Dependency getDependency(Operator<? extends OperatorDesc> op,
                                            ColumnInfo col)

Gets the dependency for an operator, columninfo tuple.

Parameters:

op - The operator whose dependency is being inspected.

col - The column info whose dependency is being inspected.

Returns:

Dependency for that particular operator, columninfo tuple. null if no dependency is found.

putDependency

public void putDependency(Operator<? extends OperatorDesc> op,
                          ColumnInfo col,
                          LineageInfo.Dependency dep)

Puts the dependency for an operator, columninfo tuple.

Parameters:

op - The operator whose dependency is being inserted.

col - The column info whose dependency is being inserted.

dep - The dependency.

mergeDependency

public void mergeDependency(Operator<? extends OperatorDesc> op,
                            ColumnInfo ci,
                            LineageInfo.Dependency dep)

Merges the new dependencies in dep to the existing dependencies of (op, ci).

Parameters:

op - The operator of the column whose dependency is being modified.

ci - The column info of the associated column.

dep - The new dependency.

clear

public void clear()