public class EventHubLoop extends EventCount
A sample topology that loops message back to EventHub
numWorkers, spoutConfig| Constructor and Description |
|---|
EventHubLoop() |
| Modifier and Type | Method and Description |
|---|---|
protected StormTopology |
buildTopology(EventHubSpout eventHubSpout) |
static void |
main(String[] args) |
createEventHubSpout, readEHConfig, runScenario, submitTopologyprotected StormTopology buildTopology(EventHubSpout eventHubSpout)
buildTopology in class EventCountCopyright © 2022 The Apache Software Foundation. All Rights Reserved.