Package backtype.storm.generated

Examples of backtype.storm.generated.GlobalStreamId


        return builder.createTopology();
    }
   
    private void markBatchGroups(String component, Map<String, String> batchGroups) {
        for(String stream: batchGroups.keySet()) {
            _batchIds.put(new GlobalStreamId(component, stream), batchGroups.get(stream));
        }
    }
View Full Code Here


   
    List<GlobalStreamId> getBoltSubscriptionStreams(String id) {
        List<GlobalStreamId> ret = new ArrayList();
        Component c = _bolts.get(id);
        for(InputDeclaration d: c.declarations) {
            ret.add(new GlobalStreamId(d.getComponent(), d.getStream()));
        }
        return ret;
    }
View Full Code Here

  }

  public Map<String, Map<GlobalStreamId, Double>> get_recv_tps() {
    Map<Integer, Object> statics = staticsMap.get(StaticsType.recv_tps);

    GlobalStreamId streamIdSample = new GlobalStreamId("", "");
    return convertKey(statics, streamIdSample, Double.valueOf(0));
  }
View Full Code Here

  }

  public Map<String, Map<GlobalStreamId, Long>> get_acked() {
    Map<Integer, Object> statics = staticsMap.get(StaticsType.acked);

    GlobalStreamId streamIdSample = new GlobalStreamId("", "");
    return convertKey(statics, streamIdSample, Long.valueOf(0));
  }
View Full Code Here

  }

  public Map<String, Map<GlobalStreamId, Long>> get_failed() {
    Map<Integer, Object> statics = staticsMap.get(StaticsType.failed);

    GlobalStreamId streamIdSample = new GlobalStreamId("", "");
    return convertKey(statics, streamIdSample, Long.valueOf(0));
  }
View Full Code Here

        new HashMap<String, Map<GlobalStreamId,Double>>();
   
    Map<Integer, Object> statics = staticsMap
        .get(StaticsType.process_latencies);

    GlobalStreamId streamIdSample = new GlobalStreamId("", "");
   
    Map<String, Map<GlobalStreamId, Double>> raw =
        convertKey(statics, streamIdSample, Double.valueOf(0));
   
    for (Entry<String, Map<GlobalStreamId, Double>> windowEntry : raw.entrySet()) {
      String windowStr = windowEntry.getKey();
      Map<GlobalStreamId, Double> oldStreamMap = windowEntry.getValue();
     
      Map<GlobalStreamId, Double> newStreamMap = new HashMap<GlobalStreamId, Double>();
     
      for (Entry<GlobalStreamId, Double> entry: oldStreamMap.entrySet()) {
        GlobalStreamId key = entry.getKey();
        Double         value = entry.getValue();
       
        if (value == null) {
          newStreamMap.put(key, Double.valueOf(0));
        }else {
View Full Code Here

    }

    Integer recv = sampler.tpsCheck();

    if (recv != null) {
      GlobalStreamId key = new GlobalStreamId(component, stream);
      update_task_stat(StaticsType.recv_tps, key, recv);
    }
  }
View Full Code Here

    if (pair == null) {
      return;
    }
   
    long avgLatency = (long)((double)pair.getSecond());
    GlobalStreamId key = new GlobalStreamId(component, stream);
    update_task_stat(StaticsType.acked, key, pair.getFirst());
    update_task_stat(StaticsType.process_latencies, key, avgLatency);
  }
View Full Code Here

    Integer times = sampler.timesCheck();
    if (times == null) {
      return;
    }

    GlobalStreamId key = new GlobalStreamId(component, stream);
    update_task_stat(StaticsType.failed, key, times);
  }
View Full Code Here

    if (pair == null) {
      return;
    }
   
    long avgLatency = (long)((double)pair.getSecond());
    GlobalStreamId key = new GlobalStreamId(Common.ACKER_COMPONENT_ID,
        stream);
    update_task_stat(StaticsType.acked, key, pair.getFirst());
    update_task_stat(StaticsType.process_latencies, key, avgLatency);
  }
View Full Code Here

TOP

Related Classes of backtype.storm.generated.GlobalStreamId

Copyright © 2018 www.massapicom. 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.