org.thales.punch.libraries.storm.bolt.impl

Class JsonKafkaOutput

java.lang.Object

org.thales.punch.libraries.storm.api.BaseProcessingNode

org.thales.punch.libraries.storm.bolt.AbstractKafkaOutput

org.thales.punch.libraries.storm.bolt.impl.JsonKafkaOutput

All Implemented Interfaces:

Serializable, org.apache.storm.task.IBolt, org.apache.storm.topology.IComponent, org.apache.storm.topology.IRichBolt

public class JsonKafkaOutput
extends AbstractKafkaOutput

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.thales.punch.libraries.storm.bolt.AbstractKafkaOutput

AbstractKafkaOutput.Topic

Field Summary

Fields inherited from class org.thales.punch.libraries.storm.bolt.AbstractKafkaOutput

boltProducer, exitOnFailure, producerProperties, settings

Fields inherited from class org.thales.punch.libraries.storm.api.BaseProcessingNode

ackRate, collector, componentId, every, failRate, metricContext, nodeSettings, topologyContext, traversalTime

Constructor Summary

Constructors

Constructor and Description
JsonKafkaOutput(org.thales.punch.libraries.storm.api.NodeSettings boltConfig, Properties producerProperties)

Method Summary

Modifier and Type	Method and Description
void	prepare(Map conf, org.apache.storm.task.TopologyContext context, org.apache.storm.task.OutputCollector collector)
void	process(org.apache.storm.tuple.Tuple tuple)

Methods inherited from class org.thales.punch.libraries.storm.bolt.AbstractKafkaOutput

declareOutputFields, getTargetTopic, sendKafkaMessage

Methods inherited from class org.thales.punch.libraries.storm.api.BaseProcessingNode

ack, cleanup, enrichAndForwardMonitoringTuple, execute, fail, getComponentConfiguration, getNewPoint

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JsonKafkaOutput

public JsonKafkaOutput(org.thales.punch.libraries.storm.api.NodeSettings boltConfig,
                       Properties producerProperties)
                throws org.thales.punch.exceptions.ConfigurationException

Throws:

org.thales.punch.exceptions.ConfigurationException

Method Detail

prepare

public void prepare(Map conf,
                    org.apache.storm.task.TopologyContext context,
                    org.apache.storm.task.OutputCollector collector)

Specified by:

prepare in interface org.apache.storm.task.IBolt

Overrides:

prepare in class AbstractKafkaOutput

process

public void process(org.apache.storm.tuple.Tuple tuple)

Specified by:

process in class org.thales.punch.libraries.storm.api.BaseProcessingNode