public class GeneratorSpoutFactory extends Object implements org.thales.punch.libraries.storm.api.ISpoutFactory
Modifier and Type | Field and Description |
---|---|
static String |
TYPE
The key referencing the associated spout.
|
Constructor and Description |
---|
GeneratorSpoutFactory()
Default constructor.
|
Modifier and Type | Method and Description |
---|---|
GeneratorInput |
createSpout(org.thales.punch.libraries.storm.api.NodeSettings spoutConfig,
org.thales.punch.libraries.storm.api.ITopologySettings topoConfig,
org.thales.punch.platform.api.IPunchPlatformProperties punchplatformConfig) |
List<org.thales.punch.libraries.storm.api.StreamDeclaration> |
getPublishedStreamConfig(org.thales.punch.libraries.storm.api.NodeSettings spoutSettings) |
public static final String TYPE
public GeneratorInput createSpout(org.thales.punch.libraries.storm.api.NodeSettings spoutConfig, org.thales.punch.libraries.storm.api.ITopologySettings topoConfig, org.thales.punch.platform.api.IPunchPlatformProperties punchplatformConfig)
createSpout
in interface org.thales.punch.libraries.storm.api.ISpoutFactory
public List<org.thales.punch.libraries.storm.api.StreamDeclaration> getPublishedStreamConfig(org.thales.punch.libraries.storm.api.NodeSettings spoutSettings)
getPublishedStreamConfig
in interface org.thales.punch.libraries.storm.api.ISpoutFactory
Copyright © 2023. All rights reserved.