storm.trident.planner.processor
Class AggregateProcessor
java.lang.Object
storm.trident.planner.processor.AggregateProcessor
- All Implemented Interfaces:
- java.io.Serializable, TridentProcessor, TupleReceiver
public class AggregateProcessor
- extends java.lang.Object
- implements TridentProcessor
- See Also:
- Serialized Form
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
AggregateProcessor
public AggregateProcessor(Fields inputFields,
Aggregator agg)
prepare
public void prepare(java.util.Map conf,
TopologyContext context,
TridentContext tridentContext)
- Specified by:
prepare
in interface TridentProcessor
cleanup
public void cleanup()
- Specified by:
cleanup
in interface TridentProcessor
startBatch
public void startBatch(ProcessorContext processorContext)
- Specified by:
startBatch
in interface TridentProcessor
execute
public void execute(ProcessorContext processorContext,
java.lang.String streamId,
TridentTuple tuple)
- Specified by:
execute
in interface TupleReceiver
finishBatch
public void finishBatch(ProcessorContext processorContext)
- Specified by:
finishBatch
in interface TridentProcessor
getOutputFactory
public TridentTuple.Factory getOutputFactory()
- Specified by:
getOutputFactory
in interface TridentProcessor