org.thales.punch.libraries.storm.bolt.factory

Class KafkaBoltFactory

java.lang.Object

org.thales.punch.libraries.storm.bolt.factory.KafkaBoltFactory

All Implemented Interfaces:

org.thales.punch.libraries.storm.api.IBoltFactory

public class KafkaBoltFactory
extends Object
implements org.thales.punch.libraries.storm.api.IBoltFactory

Build a Storm topology.

Author:

dimi

Field Summary

Fields

Modifier and Type	Field and Description
static String	TYPE The key referencing the associated bolt.

Constructor Summary

Constructors

Constructor and Description
KafkaBoltFactory() Default constructor.

Method Summary

Modifier and Type	Method and Description
org.apache.storm.topology.IRichBolt	createBolt(org.thales.punch.platform.api.IPlatform platform, org.thales.punch.libraries.storm.api.NodeSettings boltConfig, org.thales.punch.libraries.storm.api.ITopologySettings topoConfig)
protected Properties	createComponentSettings(org.thales.punch.libraries.storm.api.NodeSettings boltConfig, org.thales.punch.libraries.storm.api.ITopologySettings topoConfig, org.thales.punch.platform.api.IPunchPlatformProperties punchplatformConfig) Creates settings needed by the Kafka producer.
List<org.thales.punch.libraries.storm.api.StreamDeclaration>	getPublishedStreamConfig(org.thales.punch.libraries.storm.api.NodeSettings boltSettings)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.thales.punch.libraries.storm.api.IBoltFactory

getStaticResources

Field Detail

TYPE

public static final String TYPE

The key referencing the associated bolt.

See Also:

Constant Field Values

Constructor Detail

KafkaBoltFactory

public KafkaBoltFactory()

Default constructor.

Method Detail

getPublishedStreamConfig

public List<org.thales.punch.libraries.storm.api.StreamDeclaration> getPublishedStreamConfig(org.thales.punch.libraries.storm.api.NodeSettings boltSettings)

Specified by:

getPublishedStreamConfig in interface org.thales.punch.libraries.storm.api.IBoltFactory

createBolt

public org.apache.storm.topology.IRichBolt createBolt(org.thales.punch.platform.api.IPlatform platform,
                                                      org.thales.punch.libraries.storm.api.NodeSettings boltConfig,
                                                      org.thales.punch.libraries.storm.api.ITopologySettings topoConfig)
                                               throws org.thales.punch.exceptions.ConfigurationException

Specified by:

createBolt in interface org.thales.punch.libraries.storm.api.IBoltFactory

Throws:

org.thales.punch.exceptions.ConfigurationException

createComponentSettings

protected Properties createComponentSettings(org.thales.punch.libraries.storm.api.NodeSettings boltConfig,
                                             org.thales.punch.libraries.storm.api.ITopologySettings topoConfig,
                                             org.thales.punch.platform.api.IPunchPlatformProperties punchplatformConfig)
                                      throws org.thales.punch.exceptions.ConfigurationException

Creates settings needed by the Kafka producer. The bolt settings can embed native kafka properties, prefixed by "producer.". These are extracted and grouped in a standard Properties bag, ready to be used by the bolt.

Parameters:

boltConfig - the bolt configuration.

topoConfig - topoconfig

punchplatformConfig - punchplatformConfig

Returns:

properties needed by the kafka producer embedded in the bolt

Throws:

org.thales.punch.exceptions.ConfigurationException