Package org.apache.storm.perf

Class HdfsSpoutNullBoltTopo

java.lang.Object

org.apache.storm.perf.HdfsSpoutNullBoltTopo

public class HdfsSpoutNullBoltTopo
extends Object

This topo helps measure speed of reading from Hdfs.

Spout Reads from Hdfs.

Bolt acks and discards tuples.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_BOLT_NUM
static final int	DEFAULT_SPOUT_NUM

Constructor Summary

Constructors

Constructor	Description
HdfsSpoutNullBoltTopo()

Method Summary

Modifier and Type	Method	Description
static void	main(String[] args)

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_SPOUT_NUM

public static final int DEFAULT_SPOUT_NUM

See Also:

• Constant Field Values

DEFAULT_BOLT_NUM

public static final int DEFAULT_BOLT_NUM

See Also:

• Constant Field Values

Constructor Details

HdfsSpoutNullBoltTopo

public HdfsSpoutNullBoltTopo()

Method Details

main

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

Throws:

Exception