public class PunchBoltFactory extends Object implements org.thales.punch.libraries.storm.api.IBoltFactory
Modifier and Type | Field and Description |
---|---|
static String |
TYPE
The key referencing the associated bolt.
|
Constructor and Description |
---|
PunchBoltFactory()
Default constructor.
|
Modifier and Type | Method and Description |
---|---|
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) |
static PunchletConfig |
getPunchletConfig(org.thales.punch.settings.api.ISettingsMap nodeSettings,
org.thales.punch.libraries.storm.api.ITopologySettings topoSettings,
String defaultGrokPatterns) |
static PunchletConfig |
getPunchletConfig(org.thales.punch.settings.api.ISettingsMap nodeSettings,
String tenantName,
String channelName,
org.thales.punch.libraries.storm.api.ITopologySettings topoConfig)
Load all the required resource and punchlet files and return a ready to use
PunchletConfig.
|
static PunchletConfig |
getPunchletConfig(org.thales.punch.settings.api.ISettingsMap nodeSettings,
String tenantName,
String channelName,
org.thales.punch.libraries.storm.api.ITopologySettings topoSettings,
String defaultGrokPatterns,
Path defaultResourcePath)
This method looks for punchlets in a local configuration directory.
|
public static final String TYPE
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 PunchletConfig getPunchletConfig(org.thales.punch.settings.api.ISettingsMap nodeSettings, String tenantName, String channelName, org.thales.punch.libraries.storm.api.ITopologySettings topoConfig)
A dry compilation run is also performed to detect upfront invalid punchlets.
platform
- platformnodeSettings
- componentSettingstenantName
- tenantNamechannelName
- channelNametopoConfig
- topoConfigorg.thales.punch.exceptions.ConfigurationException
IOException
public static PunchletConfig getPunchletConfig(org.thales.punch.settings.api.ISettingsMap nodeSettings, String tenantName, String channelName, org.thales.punch.libraries.storm.api.ITopologySettings topoSettings, String defaultGrokPatterns, Path defaultResourcePath) throws IOException
nodeSettings
- the punch node settingstenantName
- the tenant namechannelName
- the channel nametopoSettings
- defaultResourcePath
- the default location where to look for resources.IOException
- in case resource or punchlet files could not be loaded.public static PunchletConfig getPunchletConfig(org.thales.punch.settings.api.ISettingsMap nodeSettings, org.thales.punch.libraries.storm.api.ITopologySettings topoSettings, String defaultGrokPatterns) throws IOException
IOException
Copyright © 2023. All rights reserved.