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

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

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

Collectors.summingLong介绍

暂无

代码示例

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

  1. /**
  2.  * Computes the size of each store file in {@code storeFileNames}
  3.  */
  4. long getSizeOfStoreFiles(TableName tn, Set<StoreFileReference> storeFileNames) {
  5.  return storeFileNames.stream()
  6.    .collect(Collectors.summingLong((sfr) -> getSizeOfStoreFile(tn, sfr)));
  7. }

代码示例来源：origin: Graylog2/graylog2-server

  1. private TreeMap<DateTime, Long> aggregateToDaily(Map<DateTime, Long> histogram) {
  2.   return histogram.entrySet().stream()
  3.       .collect(Collectors.groupingBy(entry -> entry.getKey().withTimeAtStartOfDay(),
  4.           TreeMap::new,
  5.           Collectors.mapping(Map.Entry::getValue, Collectors.summingLong(Long::valueOf))));
  6. }

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

  1. /**
  2.  * Computes the size of the store files for a single region.
  3.  */
  4. long getSizeOfStoreFile(TableName tn, StoreFileReference storeFileName) {
  5.  String regionName = storeFileName.getRegionName();
  6.  return storeFileName.getFamilyToFilesMapping()
  7.    .entries().stream()
  8.    .collect(Collectors.summingLong((e) ->
  9.      getSizeOfStoreFile(tn, regionName, e.getKey(), e.getValue())));
  10. }

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

  1. @Override
  2. public Mono<Long> delete(Publisher<K> keys) {
  3.   Assert.notNull(keys, "Keys must not be null!");
  4.   return createFlux(connection -> connection.keyCommands() //
  5.       .mDel(Flux.from(keys).map(this::rawKey).buffer(128)) //
  6.       .map(CommandResponse::getOutput)) //
  7.       .collect(Collectors.summingLong(value -> value));
  8. }

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

  1. @Override
  2. public Mono<Long> unlink(Publisher<K> keys) {
  3.   Assert.notNull(keys, "Keys must not be null!");
  4.   return createFlux(connection -> connection.keyCommands() //
  5.       .mUnlink(Flux.from(keys).map(this::rawKey).buffer(128)) //
  6.       .map(CommandResponse::getOutput)) //
  7.       .collect(Collectors.summingLong(value -> value));
  8. }

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

  1. public long longSize() {
  2.   return this.map.values().stream().collect(Collectors.summingLong(Long::longValue));
  3. }

代码示例来源：origin: com.tinkerpop/gremlin-core

  1. public long longSize() {
  2.   return this.map.values().stream().collect(Collectors.summingLong(Long::longValue));
  3. }

代码示例来源：origin: org.apache.commons/commons-rdf-jsonld-java

  1. @Override
  2. public long size() {
  3.   return rdfDataSet.graphNames().stream().map(rdfDataSet::getQuads)
  4.       .collect(Collectors.summingLong(List::size));
  5. }

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

  1. @Override
  2. public long sumLong(ToLongFunction<? super T> function) {
  3.   return collect(Collectors.summingLong(function));
  4. }

代码示例来源：origin: radixdlt/radixdlt-java

  1. public Map<Set<ECPublicKey>, Map<EUID, Long>> summary() {
  2.   return getParticles().stream()
  3.     .filter(Particle::isAbstractConsumable)
  4.     .map(Particle::getAsAbstractConsumable)
  5.     .collect(Collectors.groupingBy(
  6.       AbstractConsumable::getOwnersPublicKeys,
  7.       Collectors.groupingBy(
  8.         AbstractConsumable::getAssetId,
  9.         Collectors.summingLong(AbstractConsumable::getSignedQuantity)
  10.       )
  11.     ));
  12. }

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

  1. @Override
  2. public long sumLong(ToLongFunction<? super T> function) {
  3.   return collect(Collectors.summingLong(function));
  4. }

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

  1. public void dump(long l, StringBuilder str) {
  2.     long ms = this.children.stream()
  3.         .collect(Collectors.summingLong(e -> e.durationMs()));
  5.     str.append(String.format("%-80s...%s", this.description, Performance.formatTime(ms)));
  6.     str.append("\n");
  7.   }
  8. }

代码示例来源：origin: org.graylog2/graylog2-server

  1. private TreeMap<DateTime, Long> aggregateToDaily(Map<DateTime, Long> histogram) {
  2.   return histogram.entrySet().stream()
  3.       .collect(Collectors.groupingBy(entry -> entry.getKey().withTimeAtStartOfDay(),
  4.           TreeMap::new,
  5.           Collectors.mapping(Map.Entry::getValue, Collectors.summingLong(Long::valueOf))));
  6. }

代码示例来源：origin: Adobe-Consulting-Services/acs-aem-commons

  1. private long getTotalAssetSize(Asset asset) {
  2.   long size = asset.getRenditions().stream().collect(Collectors.summingLong(r -> r.getSize()));
  3.   if (includeSubassets && !asset.isSubAsset()) {
  4.     size += DamUtil.getSubAssets(asset.adaptTo(Resource.class)).stream().collect(Collectors.summingLong(this::getTotalAssetSize));
  5.   }
  6.   return size;
  7. }

代码示例来源：origin: org.apache.commons/commons-rdf-jena

  1. @Override
  2. public long size() {
  3.   final long quads = Iter.asStream(datasetGraph.listGraphNodes())
  4.       .map(datasetGraph::getGraph)
  5.       .collect(Collectors.summingLong(org.apache.jena.graph.Graph::size));
  6.   return quads + datasetGraph.getDefaultGraph().size();
  7. }

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

  1. @Override
  2. public Mono<Long> delete(Publisher<K> keys) {
  3.   Assert.notNull(keys, "Keys must not be null!");
  4.   return createFlux(connection -> connection.keyCommands() //
  5.       .mDel(Flux.from(keys).map(this::rawKey).buffer(128)) //
  6.       .map(CommandResponse::getOutput)) //
  7.       .collect(Collectors.summingLong(value -> value));
  8. }

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

  1. @Override
  2. public Mono<Long> unlink(Publisher<K> keys) {
  3.   Assert.notNull(keys, "Keys must not be null!");
  4.   return createFlux(connection -> connection.keyCommands() //
  5.       .mUnlink(Flux.from(keys).map(this::rawKey).buffer(128)) //
  6.       .map(CommandResponse::getOutput)) //
  7.       .collect(Collectors.summingLong(value -> value));
  8. }

代码示例来源：origin: apache/servicemix-bundles

  1. @Override
  2. public Mono<Long> delete(Publisher<K> keys) {
  3.   Assert.notNull(keys, "Keys must not be null!");
  4.   return createFlux(connection -> connection.keyCommands() //
  5.       .mDel(Flux.from(keys).map(this::rawKey).buffer(128)) //
  6.       .map(CommandResponse::getOutput)) //
  7.       .collect(Collectors.summingLong(value -> value));
  8. }

代码示例来源：origin: apache/servicemix-bundles

  1. @Override
  2. public Mono<Long> unlink(Publisher<K> keys) {
  3.   Assert.notNull(keys, "Keys must not be null!");
  4.   return createFlux(connection -> connection.keyCommands() //
  5.       .mUnlink(Flux.from(keys).map(this::rawKey).buffer(128)) //
  6.       .map(CommandResponse::getOutput)) //
  7.       .collect(Collectors.summingLong(value -> value));
  8. }

代码示例来源：origin: fhoeben/hsac-fitnesse-fixtures

  1. protected void writePieChartGeneratorBody(ChartWriter writer, List<TestReportHtml> htmls) {
  2.   List<TestReportHtml> nonOverviews = filterBy(htmls, r -> !r.isOverviewPage());
  3.   writeStatusPieChartGenerator(writer, nonOverviews);
  4.   writer.writePieChartGenerator("Tests / Run", TESTCOUNT_CHART_ID, nonOverviews,
  5.       r -> r.getRunName(), Collectors.counting());
  6.   writer.writePieChartGenerator("Time / Run", RUNTIME_CHART_ID, nonOverviews,
  7.       r -> r.getRunName(), Collectors.summingLong(r -> r.getTime() < 0 ? 0 : r.getTime()));
  8.   writer.writeBarChartGenerator("ms / Test", TIME_PER_TEST_CHART_ID,
  9.       ",hAxis:{textPosition:'none'}");
  10. }

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

Collectors

相关文章

    查看更多

    热门标签

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

    最新文章

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