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

Class SFTPSpoutFactory

java.lang.Object

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

All Implemented Interfaces:

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

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

Field Summary

Fields

Modifier and Type	Field and Description
static String	CHECKPOINT_SETTINGS
static String	CLEANUP
static String	CONSUMER_MODE
static String	CONSUMER_MODE_DEFAULT
static String	DOWNLOAD_ADD_SUFFIX
static String	DOWNLOAD_IGNORE_SUFFIX
static String	DOWNLOAD_PATH
static String	FILE_COMPLETE_MARKER
static String	SFTP_SETTINGS
static String	TYPE

Constructor Summary

Constructors

Constructor and Description
SFTPSpoutFactory()

Method Summary

Modifier and Type	Method and Description
org.thales.punch.libraries.storm.api.ISpout	createSpout(org.thales.punch.libraries.storm.api.NodeSettings nodeSettings, 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

SFTP_SETTINGS

public static final String SFTP_SETTINGS

See Also:

Constant Field Values

CLEANUP

public static final String CLEANUP

See Also:

Constant Field Values

DOWNLOAD_PATH

public static final String DOWNLOAD_PATH

See Also:

Constant Field Values

FILE_COMPLETE_MARKER

public static final String FILE_COMPLETE_MARKER

See Also:

Constant Field Values

DOWNLOAD_IGNORE_SUFFIX

public static final String DOWNLOAD_IGNORE_SUFFIX

See Also:

Constant Field Values

DOWNLOAD_ADD_SUFFIX

public static final String DOWNLOAD_ADD_SUFFIX

See Also:

Constant Field Values

CHECKPOINT_SETTINGS

public static final String CHECKPOINT_SETTINGS

See Also:

Constant Field Values

CONSUMER_MODE

public static final String CONSUMER_MODE

See Also:

Constant Field Values

CONSUMER_MODE_DEFAULT

public static final String CONSUMER_MODE_DEFAULT

See Also:

Constant Field Values

Constructor Detail

SFTPSpoutFactory

public SFTPSpoutFactory()

Method Detail

createSpout

public org.thales.punch.libraries.storm.api.ISpout createSpout(org.thales.punch.libraries.storm.api.NodeSettings nodeSettings,
                                                               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