public class KafkaBolt<K,V> extends BaseRichBolt
Constructor and Description |
---|
KafkaBolt() |
Modifier and Type | Method and Description |
---|---|
void |
cleanup()
Called when an IBolt is going to be shutdown.
|
void |
declareOutputFields(OutputFieldsDeclarer declarer)
Declare the output schema for all the streams of this topology.
|
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.
|
void |
setAsync(boolean async) |
void |
setFireAndForget(boolean fireAndForget) |
KafkaBolt<K,V> |
withProducerProperties(Properties producerProperties) |
KafkaBolt<K,V> |
withTopicSelector(KafkaTopicSelector selector) |
KafkaBolt<K,V> |
withTupleToKafkaMapper(TupleToKafkaMapper<K,V> mapper) |
getComponentConfiguration
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getComponentConfiguration
public static final String TOPIC
public KafkaBolt<K,V> withTopicSelector(KafkaTopicSelector selector)
public KafkaBolt<K,V> withProducerProperties(Properties producerProperties)
public void prepare(Map stormConf, TopologyContext context, OutputCollector collector)
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
input
- The input tuple to be processed.public void declareOutputFields(OutputFieldsDeclarer declarer)
IComponent
declarer
- this is used to declare output stream ids, output fields, and whether or not each output stream is a direct streampublic void cleanup()
IBolt
cleanup
in interface IBolt
cleanup
in class BaseRichBolt
public void setFireAndForget(boolean fireAndForget)
public void setAsync(boolean async)
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.