org.apache.storm.eventhubs.samples

Class EventCount

java.lang.Object

org.apache.storm.eventhubs.samples.EventCount

Direct Known Subclasses:

AtMostOnceEventCount, EventHubLoop, OpaqueTridentEventCount, TransactionalTridentEventCount

public class EventCount
extends Object

The basic scenario topology that uses EventHubSpout with PartialCountBolt and GlobalCountBolt. To submit this topology: storm jar {jarfile} {classname} {topologyname} {spoutconffile}

Field Summary

Fields

Modifier and Type	Field and Description
protected int	numWorkers
protected EventHubSpoutConfig	spoutConfig

Constructor Summary

Constructors

Constructor and Description
EventCount()

Method Summary

Modifier and Type	Method and Description
protected StormTopology	buildTopology(EventHubSpout eventHubSpout)
protected EventHubSpout	createEventHubSpout()
static void	main(String[] args)
protected void	readEHConfig(String[] args)
protected void	runScenario(String[] args)
protected void	submitTopology(String[] args, StormTopology topology)

Methods inherited from class java.lang.Object

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

Field Detail

spoutConfig

protected EventHubSpoutConfig spoutConfig

numWorkers

protected int numWorkers

Constructor Detail

EventCount

public EventCount()

Method Detail

readEHConfig

protected void readEHConfig(String[] args)
                     throws Exception

Throws:

Exception

createEventHubSpout

protected EventHubSpout createEventHubSpout()

buildTopology

protected StormTopology buildTopology(EventHubSpout eventHubSpout)

submitTopology

protected void submitTopology(String[] args,
                              StormTopology topology)
                       throws Exception

Throws:

Exception

runScenario

protected void runScenario(String[] args)
                    throws Exception

Throws:

Exception

main

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

Throws:

Exception