Package com.alipay.bluewhale.core.cluster

Examples of com.alipay.bluewhale.core.cluster.StormClusterState.assignment_info()

373
374
375
376
377
378
379
380
381
382
383
    Set<Entry<String, StormBase>> basesEntry = bases.entrySet();
    for (Iterator<Entry<String, StormBase>> it = basesEntry.iterator(); it.hasNext();) {
      Entry<String, StormBase> entry = it.next();
      String stormId = entry.getKey();
      StormBase base = entry.getValue();
      Assignment assignment = stormClusterState.assignment_info(stormId,null);
      if (assignment != null) {
        HashSet<NodePort> workers = new HashSet<NodePort>();
        Collection<NodePort> entryColl = assignment.getTaskToNodeport().values();
        workers.addAll(entryColl);
        topologySummaries.add(new TopologySummary(stormId, base.getStormName(), assignment.getTaskToNodeport().size(),
View Full Code Here
412
413
414
415
416
417
418
419
420
421
422
   
    //���topology��name������ʱ���״̬
    StormBase base = stormClusterState.storm_base(topologyId, null);
   
    //���topology�����������Ϣ
    Assignment assignment = stormClusterState.assignment_info(topologyId,null);
   
    if (base != null && assignment != null) {
      List<TaskSummary> taskSummarys = new ArrayList<TaskSummary>();
      Set<Entry<Integer, String>> taskInfoSet = taskInfo.entrySet();
      for (Iterator<Entry<Integer, String>> it = taskInfoSet.iterator(); it.hasNext();) {
View Full Code Here
31
32
33
34
35
36
37
38
39
40
41
  }
  public static List<String> getStatus(String stormId) throws Exception
  {
    StormClusterState stat=GetShards.getCluster();
   
    Assignment ass=stat.assignment_info(stormId, null);
    Map<String, String> nodeHost=(ass==null)?(new HashMap<String, String>()):ass.getNodeHost();
    Map<Integer, Integer> taskStartTimeSecs=(ass==null)?(new HashMap<Integer, Integer>()):ass.getTaskStartTimeSecs();
    Map<Integer, NodePort> taskToNodeport=(ass==null)?(new HashMap<Integer, NodePort>()):ass.getTaskToNodeport();
   
   
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
      //��ȡ���е�supervisor�ڵ���Ϣ��
      Map<String, SupervisorInfo> supInfos = allSupervisorInfo(stormClusterState, callback);
      //��ȡ<supervisorid,hostname>map���ϣ����磺node->host {"4b83cd41-e863-4bd6-b26d-3e27e5ff7799" "dw-perf-3.alipay.net","b8f1664d-5555-4950-8139-5098fb109a81" "dw-perf-2.alipay.net"}
      Map<String, String> nodeHost = getNodeHost(supInfos);
      //��ȡָ��topologyid��assignment��Ϣ��
      Assignment existingAssignment = stormClusterState.assignment_info(topologyid, null);
      //�����ȡtopology�����Ӧ�µ�NodePort
 
     
      Map<Integer, NodePort> taskNodePort = computeNewTaskToNodePort(data,
          topologyid, existingAssignment, stormClusterState, callback,
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.