Package org.apache.storm.perf
Class StrGenSpoutHdfsBoltTopo
java.lang.Object
org.apache.storm.perf.StrGenSpoutHdfsBoltTopo
This topo helps measure speed of writing to Hdfs.
 
Spout generates fixed length random strings.
Bolt writes to Hdfs.
- 
Nested Class SummaryNested Classes
- 
Field SummaryFields
- 
Constructor SummaryConstructors
- 
Method Summary
- 
Field Details- 
SPOUT_NUM- See Also:
 
- 
BOLT_NUM- See Also:
 
- 
HDFS_URI- See Also:
 
- 
HDFS_PATH- See Also:
 
- 
HDFS_BATCH- See Also:
 
- 
DEFAULT_SPOUT_NUMpublic static final int DEFAULT_SPOUT_NUM- See Also:
 
- 
DEFAULT_BOLT_NUMpublic static final int DEFAULT_BOLT_NUM- See Also:
 
- 
DEFAULT_HDFS_BATCHpublic static final int DEFAULT_HDFS_BATCH- See Also:
 
- 
TOPOLOGY_NAME- See Also:
 
- 
SPOUT_ID- See Also:
 
- 
BOLT_ID- See Also:
 
 
- 
- 
Constructor Details- 
StrGenSpoutHdfsBoltTopopublic StrGenSpoutHdfsBoltTopo()
 
- 
- 
Method Details- 
mainSpout generates random strings and HDFS bolt writes them to a text file.- Throws:
- Exception
 
 
-