org.apache.storm.perf

Class KafkaSpoutNullBoltTopo

java.lang.Object

org.apache.storm.perf.KafkaSpoutNullBoltTopo

public class KafkaSpoutNullBoltTopo
extends Object

This topo helps measure speed of reading from Kafka Spout Reads from Kafka. Bolt acks and discards tuples

Field Summary

Fields

Modifier and Type	Field and Description
static String	BOLT_ID
static String	BOLT_NUM
static int	DEFAULT_BOLT_NUM
static int	DEFAULT_SPOUT_NUM
static String	KAFKA_TOPIC
static String	SPOUT_ID
static String	SPOUT_NUM
static String	TOPOLOGY_NAME
static String	ZOOKEEPER_URI

Constructor Summary

Constructors

Constructor and Description
KafkaSpoutNullBoltTopo()

Method Summary

Modifier and Type	Method and Description
static int	getInt(Map map, Object key, int def)
static String	getStr(Map map, Object key)
static StormTopology	getTopology(Map config)
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 Detail

SPOUT_NUM

public static final String SPOUT_NUM

See Also:

Constant Field Values

BOLT_NUM

public static final String BOLT_NUM

See Also:

Constant Field Values

KAFKA_TOPIC

public static final String KAFKA_TOPIC

See Also:

Constant Field Values

ZOOKEEPER_URI

public static final String ZOOKEEPER_URI

See Also:

Constant Field Values

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

TOPOLOGY_NAME

public static final String TOPOLOGY_NAME

See Also:

Constant Field Values

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 Detail

KafkaSpoutNullBoltTopo

public KafkaSpoutNullBoltTopo()

Method Detail

getTopology

public static StormTopology getTopology(Map config)

getInt

public static int getInt(Map map,
                         Object key,
                         int def)

getStr

public static String getStr(Map map,
                            Object key)

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