org.apache.storm.eventhubs.samples

Class OpaqueTridentEventCount

java.lang.Object

org.apache.storm.eventhubs.samples.EventCount

org.apache.storm.eventhubs.samples.OpaqueTridentEventCount

public class OpaqueTridentEventCount
extends EventCount

A simple Trident topology uses OpaqueTridentEventHubSpout

Field Summary

Fields inherited from class org.apache.storm.eventhubs.samples.EventCount

numWorkers, spoutConfig

Constructor Summary

Constructors

Constructor and Description
OpaqueTridentEventCount()

Method Summary

Modifier and Type	Method and Description
protected StormTopology	buildTopology(EventHubSpout eventHubSpout)
static void	main(String[] args)

Methods inherited from class org.apache.storm.eventhubs.samples.EventCount

createEventHubSpout, readEHConfig, runScenario, submitTopology

Methods inherited from class java.lang.Object

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

Constructor Detail

OpaqueTridentEventCount

public OpaqueTridentEventCount()

Method Detail

buildTopology

protected StormTopology buildTopology(EventHubSpout eventHubSpout)

Overrides:

buildTopology in class EventCount

main

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

Throws:

Exception