java.util.stream.Collectors.summingInt()方法的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(7.5k)|赞(0)|评价(0)|浏览(366)

本文整理了Java中java.util.stream.Collectors.summingInt()方法的一些代码示例，展示了Collectors.summingInt()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Collectors.summingInt()方法的具体详情如下：
包路径：java.util.stream.Collectors
类名称：Collectors
方法名：summingInt

Collectors.summingInt介绍

暂无

代码示例

代码示例来源：origin: zalando/zalenium

  1. @Override
  2. public List<MetricFamilySamples> collect() {
  3.   GaugeMetricFamily testSessionMetric = new GaugeMetricFamily("selenium_test_sessions_running",
  4.       "The number of Selenium test sessions that are running by proxy type",
  5.       Collections.singletonList("proxy"));
  6.   Iterable<RemoteProxy> iterable = () -> proxySet.iterator();
  7.   Map<String, Integer> countByProxies = StreamSupport.stream(iterable.spliterator(), false).collect(
  8.       Collectors.groupingBy(p -> p.getClass().getSimpleName(), Collectors.summingInt(p -> p.getTotalUsed())));
  9.   
  10.   countByProxies.entrySet().stream()
  11.       .forEach(e -> testSessionMetric.addMetric(Collections.singletonList(e.getKey()), e.getValue()));
  12.   List<MetricFamilySamples> mfs = new ArrayList<MetricFamilySamples>();
  13.   mfs.add(testSessionMetric);
  14.   return mfs;
  15. }

代码示例来源：origin: Vedenin/useful-java-links

  1. long sumOdd = numbers.stream().collect(Collectors.summingInt(((p) -> p % 2 == 1 ? p : 0)));
  2. System.out.println("sumOdd = " + sumOdd); // print  sumEven = 4

代码示例来源：origin: apache/opennlp

  1. public LeipzigLanguageSampleStream(File leipzigFolder, final int sentencesPerSample,
  2.                   final int samplesPerLanguage) throws IOException {
  3.  this.sentencesPerSample = sentencesPerSample;
  4.  sentencesFiles = leipzigFolder.listFiles(new FileFilter() {
  5.   @Override
  6.   public boolean accept(File pathname) {
  7.    return !pathname.isHidden() && pathname.isFile()
  8.        && pathname.getName().length() >= 3
  9.        && pathname.getName().substring(0,3).matches("[a-z]+");
  10.   }
  11.  });
  12.  Arrays.sort(sentencesFiles);
  13.  Map<String, Integer> langCounts = Arrays.stream(sentencesFiles)
  14.    .map(file -> file.getName().substring(0, 3))
  15.    .collect(Collectors.groupingBy(String::toString, Collectors.summingInt(v -> 1)));
  16.  langSampleCounts = langCounts.entrySet().stream()
  17.    .collect(Collectors.toMap(Map.Entry::getKey, e -> samplesPerLanguage / e.getValue()));
  18.  random = new Random(23);
  19.  reset();
  20. }

代码示例来源：origin: org.lastaflute/lastaflute

  1. @Override
  2. public String toString() {
  3.   final Integer total = facadeCountMap.values().stream().collect(Collectors.summingInt(vl -> vl));
  4.   final StringBuilder sb = new StringBuilder();
  5.   sb.append("{total=").append(total);
  6.   facadeCountMap.forEach((facadeName, count) -> {
  7.     sb.append(", ").append(facadeName).append("=").append(count);
  8.   });
  9.   sb.append("}");
  10.   return sb.toString();
  11. }

代码示例来源：origin: org.lastaflute/lastaflute

  1. public String toLineDisp() { // basically format is same as requested mail count
  2.   final Map<String, Integer> resolvedMap = facadeCountMap != null ? facadeCountMap : Collections.emptyMap();
  3.   final Integer total = resolvedMap.values().stream().collect(Collectors.summingInt(vl -> vl));
  4.   final StringBuilder sb = new StringBuilder();
  5.   sb.append("{total=").append(total);
  6.   resolvedMap.forEach((facadeName, count) -> {
  7.     sb.append(", ").append(facadeName).append("=").append(count);
  8.   });
  9.   sb.append("}");
  10.   return sb.toString();
  11. }

代码示例来源：origin: lastaflute/lastaflute

  1. @Override
  2. public String toString() {
  3.   final Integer total = facadeCountMap.values().stream().collect(Collectors.summingInt(vl -> vl));
  4.   final StringBuilder sb = new StringBuilder();
  5.   sb.append("{total=").append(total);
  6.   facadeCountMap.forEach((facadeName, count) -> {
  7.     sb.append(", ").append(facadeName).append("=").append(count);
  8.   });
  9.   sb.append("}");
  10.   return sb.toString();
  11. }

代码示例来源：origin: OpenNMS/opennms

  1. @Override
  2. public int size() {
  3.   // Sum up the size of the children
  4.   int retval = getChildren().stream().collect(Collectors.summingInt(RadixTreeNode::size));
  5.   // And add 1 if our node has content
  6.   return content == null ? retval : ++retval;
  7. }

代码示例来源：origin: lastaflute/lastaflute

  1. public String toLineDisp() { // basically format is same as requested mail count
  2.   final Map<String, Integer> resolvedMap = facadeCountMap != null ? facadeCountMap : Collections.emptyMap();
  3.   final Integer total = resolvedMap.values().stream().collect(Collectors.summingInt(vl -> vl));
  4.   final StringBuilder sb = new StringBuilder();
  5.   sb.append("{total=").append(total);
  6.   resolvedMap.forEach((facadeName, count) -> {
  7.     sb.append(", ").append(facadeName).append("=").append(count);
  8.   });
  9.   sb.append("}");
  10.   return sb.toString();
  11. }

代码示例来源：origin: org.jooq/jool

  1. @Override
  2. public int sumInt(ToIntFunction<? super T> function) {
  3.   return collect(Collectors.summingInt(function));
  4. }

代码示例来源：origin: org.eobjects.datacleaner/DataCleaner-fill-pattern

  1. public int getTotalObservationCount() {
  2.   return _patterns.stream().collect(Collectors.summingInt(p -> p.getObservationCount()));
  3. }

代码示例来源：origin: org.jooq/jool-java-8

  1. @Override
  2. public int sumInt(ToIntFunction<? super T> function) {
  3.   return collect(Collectors.summingInt(function));
  4. }

代码示例来源：origin: datacleaner/DataCleaner

  1. public int getTotalObservationCount() {
  2.   return _patterns.stream().collect(Collectors.summingInt(p -> p.getObservationCount()));
  3. }

代码示例来源：origin: seleniumkit/selenograph

  1. private int toFreePercentage(Region region) {
  2.   return region.getHosts().stream().collect(summingInt(this::toFreePercentage));
  3. }

代码示例来源：origin: mcekovic/tennis-crystal-ball

  1. public void addScoreCounts(Map<PerfMatchScore, Integer> scores) {
  2.   Map<Integer, Integer> bestOfCounts = scores.entrySet().stream().collect(groupingBy(e -> e.getKey().getBestOf(), summingInt(Entry::getValue)));
  3.   for (Map.Entry<PerfMatchScore, Integer> entry : scores.entrySet()) {
  4.     int count = entry.getValue();
  5.     if (count > 0)
  6.       scoreCounts.put(entry.getKey(), new WonLost(count, bestOfCounts.get(entry.getKey().getBestOf()) - count));
  7.   }
  8. }

代码示例来源：origin: org.nuxeo.ecm.automation/nuxeo-automation-scripting

  1. @Override
  2. public int size() {
  3.   return Stream.of(doc.getParts()).collect(Collectors.summingInt(part -> part.size()));
  4. }

代码示例来源：origin: qcadoo/mes

  1. private Map<Entity, Integer> getGroupedStaffWorkTimes(Entity event) {
  2.   List<Entity> staffWorkTimes = event.getHasManyField(MaintenanceEventFields.STAFF_WORK_TIMES);
  3.   Function<Entity, Entity> toWorker = entity -> entity.getBelongsToField(StaffWorkTimeFields.WORKER);
  4.   ToIntFunction<Entity> toInt = entity -> entity.getIntegerField(StaffWorkTimeFields.LABOR_TIME);
  5.   
  6.   return staffWorkTimes.stream().collect(Collectors.groupingBy(toWorker, Collectors.summingInt(toInt)));
  7. }

代码示例来源：origin: infinispan/infinispan-simple-tutorials

  1. @Override
  2. public Integer call() throws Exception {
  3.   Cache<String, String> cache = getCache();
  4.   return cache.keySet()
  5.    .stream()
  6.      .map(e -> Integer.valueOf(e.substring(0, e.indexOf("-"))))
  7.      .collect(() -> Collectors.summingInt(Integer::intValue));
  8. }

代码示例来源：origin: spring-projects/spring-data-r2dbc

  1. @Override
  2.   public Mono<Integer> rowsUpdated() {
  3.     return Mono.from(objectToInsert).flatMapMany(toInsert -> exchange(toInsert, mappingFunction).rowsUpdated())
  4.         .collect(Collectors.summingInt(Integer::intValue));
  5.   }
  6. };

代码示例来源：origin: org.springframework.data/spring-data-r2dbc

  1. @Override
  2.   public Mono<Integer> rowsUpdated() {
  3.     return Mono.from(objectToInsert).flatMapMany(toInsert -> exchange(toInsert, mappingFunction).rowsUpdated())
  4.         .collect(Collectors.summingInt(Integer::intValue));
  5.   }
  6. };

代码示例来源：origin: epam/NGB

  1. private void testFillRange(List<Block> exons, int viewPortSize, int centerPosition, boolean forward, int bound) {
  2.   int totalLength = exons.stream()
  3.     .collect(Collectors.summingInt(e -> gffManager.calculateExonLength(e, centerPosition, forward)));
  4.   boolean isBounded;
  5.   if (forward) {
  6.     isBounded = exons.get(exons.size() - 1).getEndIndex() >= bound;
  7.   } else {
  8.     isBounded = exons.get(0).getStartIndex() <= bound;
  9.   }
  10.   Assert.assertTrue(totalLength >= viewPortSize || isBounded);
  11. }

内容来源于网络，如有侵权，请联系作者删除！

Collectors

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com