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

Constructors

Constructor and Description
Index() Constructor.

Method Summary

Modifier and Type	Method and Description
void	addFinalSelectOp(SelectOperator sop, Operator<? extends OperatorDesc> sinkOp)
void	addPredicate(Operator<? extends OperatorDesc> op, LineageInfo.Predicate cond)
void	clear()
void	copyPredicates(Operator<? extends OperatorDesc> srcOp, Operator<? extends OperatorDesc> tgtOp)
Map<ColumnInfo,LineageInfo.Dependency>	getDependencies(Operator<? extends OperatorDesc> op)
LineageInfo.Dependency	getDependency(Operator<? extends OperatorDesc> op, ColumnInfo col) Gets the dependency for an operator, columninfo tuple.
LineageInfo.Dependency	getDependency(Operator<? extends OperatorDesc> op, String internalName) Gets the dependency for a tuple of an operator, and a ColumnInfo with specified internal name.
LinkedHashMap<String,ObjectPair<SelectOperator,Table>>	getFinalSelectOps()
Set<LineageInfo.Predicate>	getPredicates(Operator<? extends OperatorDesc> op)
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

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

Constructor Detail

Index

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

getDependency

public LineageInfo.Dependency getDependency(Operator<? extends OperatorDesc> op,
                                            String internalName)

Gets the dependency for a tuple of an operator, and a ColumnInfo with specified internal name.

Parameters:

op - The operator whose dependency is being inspected.

internalName - The internal name of the column info

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.

getDependencies

public Map<ColumnInfo,LineageInfo.Dependency> getDependencies(Operator<? extends OperatorDesc> op)

addPredicate

public void addPredicate(Operator<? extends OperatorDesc> op,
                         LineageInfo.Predicate cond)

copyPredicates

public void copyPredicates(Operator<? extends OperatorDesc> srcOp,
                           Operator<? extends OperatorDesc> tgtOp)

getPredicates

public Set<LineageInfo.Predicate> getPredicates(Operator<? extends OperatorDesc> op)

addFinalSelectOp

public void addFinalSelectOp(SelectOperator sop,
                             Operator<? extends OperatorDesc> sinkOp)

getFinalSelectOps

public LinkedHashMap<String,ObjectPair<SelectOperator,Table>> getFinalSelectOps()

clear

public void clear()