public class BucketingSortingOpProcFactory extends Object
Modifier and Type | Class and Description |
---|---|
static class |
BucketingSortingOpProcFactory.DefaultInferrer |
static class |
BucketingSortingOpProcFactory.FileSinkInferrer
Processor for FileSink operator.
|
static class |
BucketingSortingOpProcFactory.ForwardingInferrer
Filter processor
|
static class |
BucketingSortingOpProcFactory.GroupByInferrer
Processor for GroupBy operator.
|
static class |
BucketingSortingOpProcFactory.JoinInferrer
Processor for Join Operator.
|
static class |
BucketingSortingOpProcFactory.MultiGroupByInferrer
Processor for GroupByOperator, the special case where it follows a ForwardOperator
There is a multi group by optimization which puts multiple group by operators in a
reducer when they share the same keys and are part of a multi insert query.
|
static class |
BucketingSortingOpProcFactory.SelectInferrer
Processor for Select operator.
|
Constructor and Description |
---|
BucketingSortingOpProcFactory() |
Modifier and Type | Method and Description |
---|---|
static SemanticNodeProcessor |
getDefaultProc() |
static SemanticNodeProcessor |
getFileSinkProc() |
static SemanticNodeProcessor |
getFilterProc() |
static SemanticNodeProcessor |
getForwardProc() |
static SemanticNodeProcessor |
getGroupByProc() |
static SemanticNodeProcessor |
getJoinProc() |
static SemanticNodeProcessor |
getLateralViewForwardProc() |
static SemanticNodeProcessor |
getLateralViewJoinProc() |
static SemanticNodeProcessor |
getLimitProc() |
static SemanticNodeProcessor |
getMultiGroupByProc() |
protected static Operator<? extends OperatorDesc> |
getParent(Stack<Node> stack)
Returns the parent operator in the walk path to the current operator.
|
static SemanticNodeProcessor |
getSelProc() |
protected static Operator<? extends OperatorDesc> getParent(Stack<Node> stack)
stack
- The stack encoding the path.public static SemanticNodeProcessor getDefaultProc()
public static SemanticNodeProcessor getJoinProc()
public static SemanticNodeProcessor getSelProc()
public static SemanticNodeProcessor getGroupByProc()
public static SemanticNodeProcessor getFileSinkProc()
public static SemanticNodeProcessor getFilterProc()
public static SemanticNodeProcessor getLimitProc()
public static SemanticNodeProcessor getLateralViewForwardProc()
public static SemanticNodeProcessor getLateralViewJoinProc()
public static SemanticNodeProcessor getForwardProc()
public static SemanticNodeProcessor getMultiGroupByProc()
Copyright © 2022 The Apache Software Foundation. All rights reserved.