org.apache.storm.eventhubs.samples

Class TransactionalTridentEventCount

java.lang.Object

org.apache.storm.eventhubs.samples.EventCount

org.apache.storm.eventhubs.samples.TransactionalTridentEventCount

public class TransactionalTridentEventCount
extends EventCount

A simple Trident topology uses TransactionalTridentEventHubSpout

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TransactionalTridentEventCount.LoggingFilter

Field Summary

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

numWorkers, spoutConfig

Constructor Summary

Constructors

Constructor and Description
TransactionalTridentEventCount()

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

TransactionalTridentEventCount

public TransactionalTridentEventCount()

Method Detail

buildTopology

protected StormTopology buildTopology(EventHubSpout eventHubSpout)

Overrides:

buildTopology in class EventCount

main

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

Throws:

Exception