public static class LineageCtx.Index extends Object
Constructor and Description |
---|
Index()
Constructor.
|
public LineageInfo.Dependency getDependency(Operator<? extends OperatorDesc> op, ColumnInfo col)
op
- The operator whose dependency is being inspected.col
- The column info whose dependency is being inspected.public LineageInfo.Dependency getDependency(Operator<? extends OperatorDesc> op, String internalName)
op
- The operator whose dependency is being inspected.internalName
- The internal name of the column infopublic void putDependency(Operator<? extends OperatorDesc> op, ColumnInfo col, LineageInfo.Dependency dep)
op
- The operator whose dependency is being inserted.col
- The column info whose dependency is being inserted.dep
- The dependency.public void mergeDependency(Operator<? extends OperatorDesc> op, ColumnInfo ci, LineageInfo.Dependency dep)
op
- The operator of the column whose dependency is being modified.ci
- The column info of the associated column.dep
- The new dependency.public Map<ColumnInfo,LineageInfo.Dependency> getDependencies(Operator<? extends OperatorDesc> op)
public void addPredicate(Operator<? extends OperatorDesc> op, LineageInfo.Predicate cond)
public void copyPredicates(Operator<? extends OperatorDesc> srcOp, Operator<? extends OperatorDesc> tgtOp)
public Set<LineageInfo.Predicate> getPredicates(Operator<? extends OperatorDesc> op)
public void addFinalSelectOp(SelectOperator sop, Operator<? extends OperatorDesc> sinkOp)
public LinkedHashMap<String,ObjectPair<SelectOperator,Table>> getFinalSelectOps()
public void clear()
Copyright © 2016 The Apache Software Foundation. All rights reserved.