org.thales.punch.libraries.storm.core.topology

Class TopologyFactory

java.lang.Object

org.thales.punch.libraries.storm.core.topology.TopologyFactory

All Implemented Interfaces:

org.thales.punch.libraries.storm.core.api.ITopologyFactory

public class TopologyFactory
extends Object
implements org.thales.punch.libraries.storm.core.api.ITopologyFactory

Build a Storm topology. The name from the configuration is suffixed with the date pattern '"yyyyMMdd-HHmmss-SSS"'.

Field Summary

Fields

Modifier and Type	Field and Description
static String	DATE_PATTERN The pattern appended to the topology name.

Constructor Summary

Constructors

Constructor and Description
TopologyFactory(org.thales.punch.libraries.storm.core.api.ITopologyRegistry registry, org.thales.punch.platform.api.IPlatform platform, String containerId) Default constructor.

Method Summary

Modifier and Type	Method and Description
protected String	buildName(org.thales.punch.libraries.storm.api.ITopologySettings config)
protected Map<String,Object>	createConfig(org.thales.punch.libraries.storm.api.ITopologySettings config) Creates a Storm topology configuration from an PunchPlatform configuration.
org.thales.punch.libraries.storm.core.api.ITopology	createEmbeddedTopology(org.thales.punch.libraries.storm.api.ITopologySettings topoConfig, List<String> pluginsJarPaths)
org.thales.punch.libraries.storm.core.api.ITopology	createLocalTopology(org.thales.punch.libraries.storm.api.ITopologySettings topoConfig, List<String> pluginsJarPaths)
org.thales.punch.libraries.storm.core.api.IRemoteTopology	createRemoteTopology(org.thales.punch.libraries.storm.api.ITopologySettings topoConfig, String jar, List<String> pluginsJarPaths)
void	createTopology(ITopologyBuilder builder, org.thales.punch.libraries.storm.api.ITopologySettings topoConfig, org.thales.punch.platform.api.IPunchPlatformProperties punchplatformConfig) Build a Storm or embedded topology from an PunchPlatform configuration.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DATE_PATTERN

public static final String DATE_PATTERN

The pattern appended to the topology name.

See Also:

Constant Field Values

Constructor Detail

TopologyFactory

public TopologyFactory(org.thales.punch.libraries.storm.core.api.ITopologyRegistry registry,
                       org.thales.punch.platform.api.IPlatform platform,
                       String containerId)

Default constructor.

Parameters:

registry - the registry of static bolt and spout factories.

platform - the platform handle

containerId - containerId

Method Detail

createLocalTopology

public org.thales.punch.libraries.storm.core.api.ITopology createLocalTopology(org.thales.punch.libraries.storm.api.ITopologySettings topoConfig,
                                                                               List<String> pluginsJarPaths)
                                                                        throws org.thales.punch.exceptions.ConfigurationException

Specified by:

createLocalTopology in interface org.thales.punch.libraries.storm.core.api.ITopologyFactory

Throws:

org.thales.punch.exceptions.ConfigurationException

createEmbeddedTopology

public org.thales.punch.libraries.storm.core.api.ITopology createEmbeddedTopology(org.thales.punch.libraries.storm.api.ITopologySettings topoConfig,
                                                                                  List<String> pluginsJarPaths)
                                                                           throws org.thales.punch.exceptions.ConfigurationException

Specified by:

createEmbeddedTopology in interface org.thales.punch.libraries.storm.core.api.ITopologyFactory

Throws:

org.thales.punch.exceptions.ConfigurationException

createRemoteTopology

public org.thales.punch.libraries.storm.core.api.IRemoteTopology createRemoteTopology(org.thales.punch.libraries.storm.api.ITopologySettings topoConfig,
                                                                                      String jar,
                                                                                      List<String> pluginsJarPaths)
                                                                               throws org.thales.punch.exceptions.ConfigurationException

Specified by:

createRemoteTopology in interface org.thales.punch.libraries.storm.core.api.ITopologyFactory

Throws:

org.thales.punch.exceptions.ConfigurationException

buildName

protected String buildName(org.thales.punch.libraries.storm.api.ITopologySettings config)

Parameters:

config - the PunchPlatform configuration.

Returns:

the topology name.

createTopology

public void createTopology(ITopologyBuilder builder,
                           org.thales.punch.libraries.storm.api.ITopologySettings topoConfig,
                           org.thales.punch.platform.api.IPunchPlatformProperties punchplatformConfig)
                    throws org.thales.punch.exceptions.ConfigurationException,
                           org.thales.punch.exceptions.EnvironmentConfigurationException

Build a Storm or embedded topology from an PunchPlatform configuration.

Parameters:

builder - builder

topoConfig - the PunchPlatform configuration.

punchplatformConfig - punchplatform config

Throws:

org.thales.punch.exceptions.ConfigurationException

org.thales.punch.exceptions.EnvironmentConfigurationException

createConfig

protected Map<String,Object> createConfig(org.thales.punch.libraries.storm.api.ITopologySettings config)

Creates a Storm topology configuration from an PunchPlatform configuration.

Parameters:

config - the PunchPlatform configuration.

Returns:

a new Storm topology configuration.