public static class BucketingSortingOpProcFactory.GroupByInferrer extends BucketingSortingOpProcFactory.DefaultInferrer implements NodeProcessor
Constructor and Description |
---|
GroupByInferrer() |
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
process(Node nd,
java.util.Stack<Node> stack,
NodeProcessorCtx procCtx,
java.lang.Object... nodeOutputs)
Generic process for all ops that don't have specific implementations.
|
protected java.lang.Object |
processGroupBy(Operator<? extends OperatorDesc> parent,
GroupByOperator gop,
BucketingSortingCtx bctx)
Process a GroupByOperator to determine which if any columns the output is bucketed and
sorted by, assumes the columns output by the parent which are bucketed and sorted have
already been determined.
|
protected void |
processGroupByReduceSink(ReduceSinkOperator rop,
GroupByOperator gop,
BucketingSortingCtx bctx)
Process the ReduceSinkOperator preceding a GroupByOperator to determine which columns
are bucketed and sorted.
|
public java.lang.Object process(Node nd, java.util.Stack<Node> stack, NodeProcessorCtx procCtx, java.lang.Object... nodeOutputs) throws SemanticException
NodeProcessor
process
in interface NodeProcessor
process
in class BucketingSortingOpProcFactory.DefaultInferrer
nd
- operator to processprocCtx
- operator processor contextnodeOutputs
- A variable argument list of outputs from other nodes in the walkSemanticException
protected void processGroupByReduceSink(ReduceSinkOperator rop, GroupByOperator gop, BucketingSortingCtx bctx)
rop
- gop
- bctx
- protected java.lang.Object processGroupBy(Operator<? extends OperatorDesc> parent, GroupByOperator gop, BucketingSortingCtx bctx)
parent
- gop
- bctx
- Copyright © 2012 The Apache Software Foundation