org.thales.punch.libraries.storm.spout.factory

Class ExtractionInputFactory

java.lang.Object

org.thales.punch.libraries.storm.spout.factory.ExtractionInputFactory

All Implemented Interfaces:

org.thales.punch.libraries.storm.api.ISpoutFactory

public class ExtractionInputFactory
extends Object
implements org.thales.punch.libraries.storm.api.ISpoutFactory

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_MODE
static String	TYPE
static String	UNDERSCORE_ID

Constructor Summary

Constructors

Constructor and Description
ExtractionInputFactory()

Method Summary

Modifier and Type	Method and Description
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)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.thales.punch.libraries.storm.api.ISpoutFactory

getPublishedStreamConfig

Field Detail

TYPE

public static final String TYPE

See Also:

Constant Field Values

DEFAULT_MODE

public static final String DEFAULT_MODE

See Also:

Constant Field Values

UNDERSCORE_ID

public static final String UNDERSCORE_ID

See Also:

Constant Field Values

Constructor Detail

ExtractionInputFactory

public ExtractionInputFactory()

Method Detail

createSpout

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)

Specified by:

createSpout in interface org.thales.punch.libraries.storm.api.ISpoutFactory