import org.apache.storm.Config;
import org.apache.storm.LocalCluster;
import org.apache.storm.topology.TopologyBuilder;
import org.apache.storm.scheduler.ExecutorDetails;
import org.apache.storm.scheduler.TopologyDetails;

public class EnergyMonitoringTopology {
    public static void main(String[] args) throws Exception {
        // Create a new instance of TopologyBuilder
        TopologyBuilder builder = new TopologyBuilder();
        
        // Configure the spout to read data from the sensor
        builder.setSpout("sensorSpout", new SensorSpout());
        
        // Configure the bolt to process the sensor data
        builder.setBolt("dataProcessorBolt", new DataProcessorBolt())
            .shuffleGrouping("sensorSpout");
        
        // Configure the bolt to visualize the processed data
        builder.setBolt("visualizationBolt", new VisualizationBolt())
            .shuffleGrouping("dataProcessorBolt");
        
        // Create a new instance of LocalCluster
        LocalCluster cluster = new LocalCluster();

        // Submit the topology to the cluster
        Config config = new Config();
        cluster.submitTopology("EnergyMonitoringTopology", config, builder.createTopology());
        
        // Wait for the topology to finish execution
        Thread.sleep(10000);
        
        // Kill the topology
        cluster.killTopology("EnergyMonitoringTopology");
        
        // Shutdown the cluster
        cluster.shutdown();
     }
}