public class TopNKeyProcessor extends Object implements SemanticNodeProcessor
Constructor and Description |
---|
TopNKeyProcessor() |
TopNKeyProcessor(int maxTopNAllowed,
float efficiencyThreshold,
long checkEfficiencyNumBatches,
int maxNumberOfPartitions) |
Modifier and Type | Method and Description |
---|---|
static Operator<? extends OperatorDesc> |
copyDown(Operator<? extends OperatorDesc> child,
OperatorDesc operatorDesc) |
Object |
process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs)
Generic process for all ops that don't have specific implementations.
|
public TopNKeyProcessor()
public TopNKeyProcessor(int maxTopNAllowed, float efficiencyThreshold, long checkEfficiencyNumBatches, int maxNumberOfPartitions)
public Object process(Node nd, Stack<Node> stack, NodeProcessorCtx procCtx, Object... nodeOutputs) throws SemanticException
SemanticNodeProcessor
process
in interface NodeProcessor
process
in interface SemanticNodeProcessor
nd
- operator to processprocCtx
- operator processor contextnodeOutputs
- A variable argument list of outputs from other nodes in the walkSemanticException
public static Operator<? extends OperatorDesc> copyDown(Operator<? extends OperatorDesc> child, OperatorDesc operatorDesc)
Copyright © 2022 The Apache Software Foundation. All rights reserved.