public class OpProcFactory extends Object
Modifier and Type | Class and Description |
---|---|
static class |
OpProcFactory.DefaultLineage
Default processor.
|
static class |
OpProcFactory.GroupByLineage
Processor for GroupBy operator.
|
static class |
OpProcFactory.JoinLineage
Processor for Join Operator.
|
static class |
OpProcFactory.LateralViewJoinLineage
Processor for Join Operator.
|
static class |
OpProcFactory.ReduceSinkLineage
ReduceSink processor.
|
static class |
OpProcFactory.SelectLineage
Processor for Select operator.
|
static class |
OpProcFactory.TableScanLineage
Processor for TableScan Operator.
|
static class |
OpProcFactory.TransformLineage
Processor for Script and UDTF Operators.
|
static class |
OpProcFactory.UnionLineage
Union processor.
|
Constructor and Description |
---|
OpProcFactory() |
Modifier and Type | Method and Description |
---|---|
static NodeProcessor |
getDefaultProc() |
static NodeProcessor |
getGroupByProc() |
static NodeProcessor |
getJoinProc() |
static NodeProcessor |
getLateralViewJoinProc() |
protected static Operator<? extends OperatorDesc> |
getParent(Stack<Node> stack)
Returns the parent operator in the walk path to the current operator.
|
static NodeProcessor |
getReduceSinkProc() |
static NodeProcessor |
getSelProc() |
static NodeProcessor |
getTransformProc() |
static NodeProcessor |
getTSProc() |
static NodeProcessor |
getUnionProc() |
protected static Operator<? extends OperatorDesc> getParent(Stack<Node> stack)
stack
- The stack encoding the path.public static NodeProcessor getJoinProc()
public static NodeProcessor getLateralViewJoinProc()
public static NodeProcessor getTSProc()
public static NodeProcessor getTransformProc()
public static NodeProcessor getSelProc()
public static NodeProcessor getGroupByProc()
public static NodeProcessor getUnionProc()
public static NodeProcessor getReduceSinkProc()
public static NodeProcessor getDefaultProc()
Copyright © 2017 The Apache Software Foundation. All rights reserved.