Java ClusterSummary类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.apache.storm.generated.ClusterSummary类的典型用法代码示例。如果您正苦于以下问题：Java ClusterSummary类的具体用法？Java ClusterSummary怎么用？Java ClusterSummary使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

ClusterSummary类属于org.apache.storm.generated包，在下文中一共展示了ClusterSummary类的4个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: printSupervisorStatistics

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 : ");
	}
}

开发者ID:PacktPublishing，项目名称:Mastering-Apache-Storm，代码行数:24，代码来源:SupervisorStatistics.java

示例2: printTopologyStatistics

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");
	}
}

开发者ID:PacktPublishing，项目名称:Mastering-Apache-Storm，代码行数:27，代码来源:TopologyStatistics.java

示例3: getTopologySummary

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;
}

开发者ID:MBtech，项目名称:stormbenchmark，代码行数:9，代码来源:MetricsUtils.java

示例4: getClusterInfo

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

开发者ID:axbaretto，项目名称:flink，代码行数:4，代码来源:FlinkLocalCluster.java

注：本文中的org.apache.storm.generated.ClusterSummary类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。