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 and Description
static int	DEFAULT_BOLT_NUM
static int	DEFAULT_SPOUT_NUM

Constructor Summary

Constructors

Constructor and Description
HdfsSpoutNullBoltTopo()

Method Summary

Modifier and Type	Method and Description
static StormTopology	getTopology(Map config)
static void	main(String[] args)

Methods inherited from class java.lang.Object

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

Field Detail

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 Detail

HdfsSpoutNullBoltTopo

public HdfsSpoutNullBoltTopo()

Method Detail

getTopology

public static StormTopology getTopology(Map config)

main

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

Throws:

Exception