paulwong

          Auto rebalance Storm

          http://stackoverflow.com/questions/15010420/storm-topology-rebalance-using-java-code


          使用Nimbus獲取STORM的信息
          http://www.andys-sundaypink.com/i/retrieve-storm-cluster-statistic-from-nimbus-java-mode/
          TSocket tsocket = new TSocket("localhost", 6627);
          TFramedTransport tTransport = new TFramedTransport(tsocket);
          TBinaryProtocol tBinaryProtocol = new TBinaryProtocol(tTransport);
          Nimbus.Client client = new Nimbus.Client(tBinaryProtocol);
          String topologyId = "test-1-234232567";


          try {

          tTransport.open();
          ClusterSummary clusterSummary = client.getClusterInfo();
          StormTopology stormTopology = client.getTopology(topologyId);
          TopologyInfo topologyInfo = client.getTopologyInfo(topologyId);
          List<ExecutorSummary> executorSummaries = topologyInfo.get_executors();

          List<TopologySummary> topologies = clusterSummary.get_topologies();
          for(ExecutorSummary executorSummary : executorSummaries){

          String id = executorSummary.get_component_id();
          ExecutorInfo executorInfo = executorSummary.get_executor_info();
          ExecutorStats executorStats = executorSummary.get_stats();
          System.out.println("executorSummary :: " + id + " emit size :: " + executorStats.get_emitted_size());
          }
          catch (TTransportException e) {
          e.printStackTrace();
          catch (TException e) {
          e.printStackTrace();
          catch (NotAliveException e) {
          e.printStackTrace();
          }




          posted on 2014-05-09 23:48 paulwong 閱讀(534) 評論(0)  編輯  收藏 所屬分類: STORM

          主站蜘蛛池模板: 新平| 双江| 福建省| 天门市| 湖口县| 辽中县| 高平市| 锡林浩特市| 施甸县| 枣阳市| 浮山县| 萨迦县| 广州市| 古交市| 中卫市| 莲花县| 旬阳县| 东光县| 广州市| 新化县| 日土县| 类乌齐县| 板桥市| 霍城县| 班玛县| 丽水市| 东乌珠穆沁旗| 蓝山县| 永康市| 东阳市| 兴化市| 赞皇县| 屯门区| 张家港市| 肃北| 垦利县| 都兰县| 黑河市| 太原市| 公安县| 栾城县|