import org.apache.storm.generated.ClusterSummary; //导入依赖的package包/类
public void printSupervisorStatistics()  {
	try {
	ThriftClient thriftClient = new ThriftClient();
	Client client = thriftClient.getClient();
	// Get the cluster information.
	ClusterSummary clusterSummary = client.getClusterInfo();
	// Get the SupervisorSummary interator
	Iterator<SupervisorSummary> supervisorsIterator = clusterSummary.get_supervisors_iterator();
	
	while (supervisorsIterator.hasNext()) {
		// Print the information of supervisor node
		SupervisorSummary supervisorSummary = (SupervisorSummary) supervisorsIterator.next();
		System.out.println("Supervisor Host IP : "+supervisorSummary.get_host());
		System.out.println("Number of used workes : "+supervisorSummary.get_num_used_workers());
		System.out.println("Number of workers : "+supervisorSummary.get_num_workers());
		System.out.println("Supervisor ID : "+supervisorSummary.get_supervisor_id());
		System.out.println("Supervisor uptime in seconds : "+supervisorSummary.get_uptime_secs());
	}
	
	}catch (Exception e) {
		throw new RuntimeException("Error occure while getting cluster info : ");
	}
}
 

import org.apache.storm.generated.ClusterSummary; //导入依赖的package包/类
public void printTopologyStatistics() {
	try {
	ThriftClient thriftClient = new ThriftClient();
	// Get the thrift client
	Client client = thriftClient.getClient();
	// Get the cluster info
	ClusterSummary clusterSummary = client.getClusterInfo();
	// Get the interator over TopologySummary class
	Iterator<TopologySummary> topologiesIterator = clusterSummary.get_topologies_iterator();
	while (topologiesIterator.hasNext()) {
		TopologySummary topologySummary = topologiesIterator.next();
		System.out.println("Topology ID: " + topologySummary.get_id());
		System.out.println("Topology Name: " + topologySummary.get_name());
		System.out.println("Number of Executors: "
				+ topologySummary.get_num_executors());
		System.out.println("Number of Tasks: " + topologySummary.get_num_tasks());
		System.out.println("Number of Workers: "
				+ topologySummary.get_num_workers());
		System.out.println("Topology status : " + topologySummary.get_status());
		System.out.println("Topology uptime in seconds: "
				+ topologySummary.get_uptime_secs());
	}
	}catch (Exception exception) {
		throw new RuntimeException("Error occure while fetching the topolgies  information");
	}
}
 

import org.apache.storm.generated.ClusterSummary; //导入依赖的package包/类
public static TopologySummary getTopologySummary(ClusterSummary cs, String name) {
  for (TopologySummary ts : cs.get_topologies()) {
    if (name.equals(ts.get_name())) {
      return ts;
    }
  }
  return null;
}
 

import org.apache.storm.generated.ClusterSummary; //导入依赖的package包/类
public ClusterSummary getClusterInfo() {
	return null;
}