public class MetricsConsumerBolt extends Object implements IBolt
Constructor and Description |
---|
MetricsConsumerBolt(String consumerClassName,
Object registrationArgument) |
Modifier and Type | Method and Description |
---|---|
void |
cleanup()
Called when an IBolt is going to be shutdown.
|
void |
execute(Tuple input)
Process a single tuple of input.
|
void |
prepare(Map stormConf,
TopologyContext context,
OutputCollector collector)
Called when a task for this component is initialized within a worker on the cluster.
|
public void prepare(Map stormConf, TopologyContext context, OutputCollector collector)
IBolt
prepare
in interface IBolt
stormConf
- The Storm configuration for this bolt. This is the configuration provided to the topology merged in with cluster configuration on this machine.context
- This object can be used to get information about this task's place within the topology, including the task id and component id of this task, input and output information, etc.collector
- The collector is used to emit tuples from this bolt. Tuples can be emitted at any time, including the prepare and cleanup methods. The collector is thread-safe and should be saved as an instance variable of this bolt object.public void execute(Tuple input)
IBolt
public void cleanup()
IBolt
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.