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, submitTopology
protected StormTopology buildTopology(EventHubSpout eventHubSpout)
buildTopology
in class EventCount
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.