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

Class OneByOneFileOutput

java.lang.Object

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

org.thales.punch.libraries.storm.bolt.AbstractFileOutput

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

All Implemented Interfaces:

Serializable, org.apache.storm.task.IBolt, org.apache.storm.topology.IComponent, org.apache.storm.topology.IRichBolt, org.thales.punch.libraries.punchlang.api.IRuntimeContext

public class OneByOneFileOutput
extends AbstractFileOutput

The "Exactly once" version of the FileBolt.
A special variation of the FileBolt that creates a dedicated file batch object for each Tuple.

See Also:

Serialized Form

Field Summary

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

archiveFormatSettings, fileNameSupplier, tupleRtt, userStream

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
OneByOneFileOutput(org.thales.punch.libraries.storm.api.NodeSettings boltConfig, List<org.thales.punch.libraries.objectstorage.tuples.ArchiveDevice> archiveDevices, IFileNameSupplier oidSupplier, org.thales.punch.libraries.objectstorage.tuples.ArchiveFormatSettings archiveFormatSettings) Ctor.

Method Summary

Modifier and Type	Method and Description
void	prepare(Map stormConf, org.apache.storm.task.TopologyContext context, org.apache.storm.task.OutputCollector outputCollector) Prepare this bolt.
void	process(org.apache.storm.tuple.Tuple tuple)

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

addRuntimeData, createArchiver, flush, getBloomFilterFields, getRuntimeData, getTimestampFromTuple, initMetadata

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

OneByOneFileOutput

public OneByOneFileOutput(org.thales.punch.libraries.storm.api.NodeSettings boltConfig,
                          List<org.thales.punch.libraries.objectstorage.tuples.ArchiveDevice> archiveDevices,
                          IFileNameSupplier oidSupplier,
                          org.thales.punch.libraries.objectstorage.tuples.ArchiveFormatSettings archiveFormatSettings)

Ctor.

Parameters:

boltConfig - the bolt settings

archiveDevices - the list of archive urls without prefix

oidSupplier - the file name supplier

archiveFormatSettings - the batch format settings

Method Detail

prepare

public void prepare(Map stormConf,
                    org.apache.storm.task.TopologyContext context,
                    org.apache.storm.task.OutputCollector outputCollector)

Description copied from class: AbstractFileOutput

Prepare this bolt. Use this directly only for testing, and only after setting what you need in terms of configuration.

Specified by:

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

Overrides:

prepare in class AbstractFileOutput

process

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

Specified by:

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