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

Class AzureBlobStorageSpoutFactory

java.lang.Object

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

All Implemented Interfaces:

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

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

Factory for the azure blob storage spout

Field Summary

Fields

Modifier and Type	Field and Description
static String	TYPE The key referencing the associated spout.

Constructor Summary

Constructors

Constructor and Description
AzureBlobStorageSpoutFactory() Ctor

Method Summary

Modifier and Type	Method and Description
org.thales.punch.libraries.storm.api.ISpout	createSpout(org.thales.punch.libraries.storm.api.NodeSettings config, org.thales.punch.libraries.storm.api.ITopologySettings topoConfig, org.thales.punch.platform.api.IPunchPlatformProperties punchplatformConfig)

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

The key referencing the associated spout.

See Also:

Constant Field Values

Constructor Detail

AzureBlobStorageSpoutFactory

public AzureBlobStorageSpoutFactory()

Ctor

Method Detail

createSpout

public org.thales.punch.libraries.storm.api.ISpout createSpout(org.thales.punch.libraries.storm.api.NodeSettings config,
                                                               org.thales.punch.libraries.storm.api.ITopologySettings topoConfig,
                                                               org.thales.punch.platform.api.IPunchPlatformProperties punchplatformConfig)

Specified by:

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