public class GenMRRedSink1 extends Object implements SemanticNodeProcessor
Constructor and Description |
---|
GenMRRedSink1() |
Modifier and Type | Method and Description |
---|---|
Object |
process(Node nd,
Stack<Node> stack,
NodeProcessorCtx opProcCtx,
Object... nodeOutputs)
Reduce Sink encountered.
|
public Object process(Node nd, Stack<Node> stack, NodeProcessorCtx opProcCtx, Object... nodeOutputs) throws SemanticException
process
in interface NodeProcessor
process
in interface SemanticNodeProcessor
nd
- the reduce sink operator encounteredopProcCtx
- contextnodeOutputs
- A variable argument list of outputs from other nodes in the walkSemanticException
Copyright © 2022 The Apache Software Foundation. All rights reserved.