org.thales.punch.libraries.storm.bolt

Class ArchiveReaderNode

java.lang.Object

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

org.thales.punch.libraries.storm.bolt.ArchiveReaderNode

All Implemented Interfaces:

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

public class ArchiveReaderNode
extends org.thales.punch.libraries.storm.api.BaseProcessingNode

Node to read archive from provided metadata

Author:

rafael

See Also:

Serialized Form

Field Summary

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
ArchiveReaderNode(org.thales.punch.libraries.storm.api.NodeSettings boltConfig) Ctor

Method Summary

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

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

ack, cleanup, declareOutputFields, 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

ArchiveReaderNode

public ArchiveReaderNode(org.thales.punch.libraries.storm.api.NodeSettings boltConfig)

Ctor

Parameters:

boltConfig - Bolt settings

Method Detail

prepare

public void prepare(Map map,
                    org.apache.storm.task.TopologyContext topologyContext,
                    org.apache.storm.task.OutputCollector collector)

Specified by:

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

Overrides:

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

process

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

Specified by:

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