public static class LineageCtx.Index extends Object implements Serializable
Constructor and Description |
---|
Index()
Constructor.
|
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.
|
Map<String,org.apache.commons.lang3.tuple.Pair<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.
|
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 Map<String,org.apache.commons.lang3.tuple.Pair<SelectOperator,Table>> getFinalSelectOps()
public void clear()
Copyright © 2023 The Apache Software Foundation. All rights reserved.