org.apache.hadoop.hive.ql.optimizer.lineage
Class OpProcFactory.UnionLineage
java.lang.Object
org.apache.hadoop.hive.ql.optimizer.lineage.OpProcFactory.DefaultLineage
org.apache.hadoop.hive.ql.optimizer.lineage.OpProcFactory.UnionLineage
- All Implemented Interfaces:
- NodeProcessor
- Enclosing class:
- OpProcFactory
public static class OpProcFactory.UnionLineage
- extends OpProcFactory.DefaultLineage
- implements NodeProcessor
Union processor.
In this case we call mergeDependency as opposed to putDependency
in order to account for visits from different parents.
OpProcFactory.UnionLineage
public OpProcFactory.UnionLineage()
process
public Object process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs)
throws SemanticException
- Description copied from interface:
NodeProcessor
- Generic process for all ops that don't have specific implementations.
- Specified by:
process
in interface NodeProcessor
- Overrides:
process
in class OpProcFactory.DefaultLineage
- Parameters:
nd
- operator to processprocCtx
- operator processor contextnodeOutputs
- A variable argument list of outputs from other nodes in the walk
- Returns:
- Object to be returned by the process call
- Throws:
SemanticException
Copyright © 2014 The Apache Software Foundation. All rights reserved.