public class CountDistinctRewriteProc.CountDistinctProcessor extends Object implements NodeProcessor
Modifier and Type | Field and Description |
---|---|
protected ParseContext |
pGraphContext |
Constructor and Description |
---|
CountDistinctProcessor(ParseContext pGraphContext) |
Modifier and Type | Method and Description |
---|---|
protected int |
checkCountDistinct(GroupByOperator mGby,
ReduceSinkOperator rs,
GroupByOperator rGby) |
Object |
process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs)
Generic process for all ops that don't have specific implementations.
|
protected void |
processGroupBy(GroupByOperator mGby,
ReduceSinkOperator rs,
GroupByOperator rGby,
int indexOfDist) |
protected ParseContext pGraphContext
public CountDistinctProcessor(ParseContext pGraphContext)
protected int checkCountDistinct(GroupByOperator mGby, ReduceSinkOperator rs, GroupByOperator rGby)
protected void processGroupBy(GroupByOperator mGby, ReduceSinkOperator rs, GroupByOperator rGby, int indexOfDist) throws SemanticException, CloneNotSupportedException
public Object process(Node nd, Stack<Node> stack, NodeProcessorCtx procCtx, Object... nodeOutputs) throws SemanticException
NodeProcessor
process
in interface NodeProcessor
nd
- operator to processprocCtx
- operator processor contextnodeOutputs
- A variable argument list of outputs from other nodes in the walkSemanticException
Copyright © 2022 The Apache Software Foundation. All rights reserved.