org.thales.punch.libraries.storm.spout.factory

Class WrapperCustomSpoutFactory

java.lang.Object

org.thales.punch.libraries.storm.spout.factory.WrapperCustomSpoutFactory

All Implemented Interfaces:

org.thales.punch.libraries.storm.api.ISpoutFactory

public class WrapperCustomSpoutFactory
extends Object
implements org.thales.punch.libraries.storm.api.ISpoutFactory

Wrapper factory to convert custom node with public API to legacy node with private API

Author:

romain

Field Summary

Fields

Modifier and Type	Field and Description
static String	TYPE

Constructor Summary

Constructors

Constructor and Description
WrapperCustomSpoutFactory() Used by DynamicTopologyRegistry
WrapperCustomSpoutFactory(String clazz)

Method Summary

Modifier and Type	Method and Description
static <T> T	bind(String settings, Class<T> clazz) Jackson mapper
org.thales.punch.libraries.storm.api.ISpout	createSpout(org.thales.punch.libraries.storm.api.NodeSettings settings, org.thales.punch.libraries.storm.api.ITopologySettings punchlineSettings, org.thales.punch.platform.api.IPunchPlatformProperties platformSettings)
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.ISpoutFactory

getPublishedStreamConfig

Field Detail

TYPE

public static final String TYPE

See Also:

Constant Field Values

Constructor Detail

WrapperCustomSpoutFactory

public WrapperCustomSpoutFactory()

Used by DynamicTopologyRegistry

WrapperCustomSpoutFactory

public WrapperCustomSpoutFactory(String clazz)

Method Detail

setClassName

public void setClassName(String className)

createSpout

public org.thales.punch.libraries.storm.api.ISpout createSpout(org.thales.punch.libraries.storm.api.NodeSettings settings,
                                                               org.thales.punch.libraries.storm.api.ITopologySettings punchlineSettings,
                                                               org.thales.punch.platform.api.IPunchPlatformProperties platformSettings)

Specified by:

createSpout in interface org.thales.punch.libraries.storm.api.ISpoutFactory

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