public class OpProcFactory extends Object
Modifier and Type | Class and Description |
---|---|
static class |
OpProcFactory.DefaultLineage
Default processor.
|
static class |
OpProcFactory.FilterLineage
Filter 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 SemanticNodeProcessor |
getDefaultProc() |
static SemanticNodeProcessor |
getFilterProc() |
static SemanticNodeProcessor |
getGroupByProc() |
static SemanticNodeProcessor |
getJoinProc() |
static SemanticNodeProcessor |
getLateralViewJoinProc() |
protected static Operator<? extends OperatorDesc> |
getParent(Stack<Node> stack)
Returns the parent operator in the walk path to the current operator.
|
static SemanticNodeProcessor |
getReduceSinkProc() |
static SemanticNodeProcessor |
getSelProc() |
static SemanticNodeProcessor |
getTransformProc() |
static SemanticNodeProcessor |
getTSProc() |
static SemanticNodeProcessor |
getUnionProc() |
protected static Operator<? extends OperatorDesc> getParent(Stack<Node> stack)
stack
- The stack encoding the path.public static SemanticNodeProcessor getJoinProc()
public static SemanticNodeProcessor getLateralViewJoinProc()
public static SemanticNodeProcessor getTSProc()
public static SemanticNodeProcessor getTransformProc()
public static SemanticNodeProcessor getSelProc()
public static SemanticNodeProcessor getGroupByProc()
public static SemanticNodeProcessor getUnionProc()
public static SemanticNodeProcessor getReduceSinkProc()
public static SemanticNodeProcessor getDefaultProc()
public static SemanticNodeProcessor getFilterProc()
Copyright © 2022 The Apache Software Foundation. All rights reserved.