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