Package org.apache.storm.hdfs.spout

Class HdfsSpoutTopology

java.lang.Object

org.apache.storm.hdfs.spout.HdfsSpoutTopology

public class HdfsSpoutTopology
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	HdfsSpoutTopology.ConstBolt

Field Summary

Fields

Modifier and Type	Field	Description
static final String	BOLT_ID
static final String	SPOUT_ID

Constructor Summary

Constructors

Constructor	Description
HdfsSpoutTopology()

Method Summary

Modifier and Type	Method	Description
static void	main(String[] args)	Copies text file content from sourceDir to destinationDir.

Methods inherited from class java.lang.Object

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

Field Details

SPOUT_ID

public static final String SPOUT_ID

See Also:

• Constant Field Values

BOLT_ID

public static final String BOLT_ID

See Also:

• Constant Field Values

Constructor Details

HdfsSpoutTopology

public HdfsSpoutTopology()

Method Details

main

public static void main(String[] args)
                 throws Exception

Copies text file content from sourceDir to destinationDir. Moves source files into sourceDir after its done consuming

Throws:

Exception