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

Class WrapperCustomBoltFactory

java.lang.Object

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

All Implemented Interfaces:

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

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

Field Summary

Fields

Modifier and Type	Field and Description
static String	TYPE

Constructor Summary

Constructors

Constructor and Description
WrapperCustomBoltFactory()
WrapperCustomBoltFactory(String clazz)

Method Summary

Modifier and Type	Method and Description
static <T> T	bind(String settings, Class<T> clazz) Jackson mapper
org.apache.storm.topology.IRichBolt	createBolt(org.thales.punch.platform.api.IPlatform platform, org.thales.punch.libraries.storm.api.NodeSettings config, org.thales.punch.libraries.storm.api.ITopologySettings topoConfig)
void	setClassName(String className)

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

getPublishedStreamConfig, getStaticResources

Field Detail

TYPE

public static final String TYPE

See Also:

Constant Field Values

Constructor Detail

WrapperCustomBoltFactory

public WrapperCustomBoltFactory()

WrapperCustomBoltFactory

public WrapperCustomBoltFactory(String clazz)

Method Detail

setClassName

public void setClassName(String className)

createBolt

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

Specified by:

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

bind

public static <T> T bind(String settings,
                         Class<T> clazz)
                  throws IOException

Jackson mapper

Parameters:

settings - NodeSettings

clazz - class to deserialize

Returns:

instance of type T

Throws:

IOException