public class WrapperCustomSpoutFactory extends Object implements org.thales.punch.libraries.storm.api.ISpoutFactory
Constructor and Description |
---|
WrapperCustomSpoutFactory()
Used by DynamicTopologyRegistry
|
WrapperCustomSpoutFactory(String clazz) |
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) |
public static final String TYPE
public WrapperCustomSpoutFactory()
public WrapperCustomSpoutFactory(String clazz)
public void setClassName(String className)
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)
createSpout
in interface org.thales.punch.libraries.storm.api.ISpoutFactory
public static <T> T bind(String settings, Class<T> clazz) throws IOException
settings
- NodeSettingsclazz
- class to deserializeIOException
Copyright © 2023. All rights reserved.