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 NodeProcessor |
getDefaultProc() |
static NodeProcessor |
getFileSinkProc() |
static NodeProcessor |
getFilterProc() |
static NodeProcessor |
getForwardProc() |
static NodeProcessor |
getGroupByProc() |
static NodeProcessor |
getJoinProc() |
static NodeProcessor |
getLateralViewForwardProc() |
static NodeProcessor |
getLateralViewJoinProc() |
static NodeProcessor |
getLimitProc() |
static NodeProcessor |
getMultiGroupByProc() |
protected static Operator<? extends OperatorDesc> |
getParent(Stack<Node> stack)
Returns the parent operator in the walk path to the current operator.
|
static NodeProcessor |
getSelProc() |
protected static Operator<? extends OperatorDesc> getParent(Stack<Node> stack)
stack
- The stack encoding the path.public static NodeProcessor getDefaultProc()
public static NodeProcessor getJoinProc()
public static NodeProcessor getSelProc()
public static NodeProcessor getGroupByProc()
public static NodeProcessor getFileSinkProc()
public static NodeProcessor getFilterProc()
public static NodeProcessor getLimitProc()
public static NodeProcessor getLateralViewForwardProc()
public static NodeProcessor getLateralViewJoinProc()
public static NodeProcessor getForwardProc()
public static NodeProcessor getMultiGroupByProc()
Copyright © 2017 The Apache Software Foundation. All rights reserved.