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

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

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

Collectors.summarizingLong介绍

暂无

代码示例

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

  1. @Override
  2. public long getSize() {
  3.   return getEventFilesFromDisk()
  4.     .collect(Collectors.summarizingLong(file -> file.length()))
  5.     .getSum();
  6. }

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

  1. private void logTimingInfo(final AsyncClusterResponse response) {
  2.   // Calculate min, max, mean for the requests
  3.   final LongSummaryStatistics stats = response.getNodesInvolved().stream()
  4.       .map(p -> response.getNodeResponse(p).getRequestDuration(TimeUnit.MILLISECONDS))
  5.       .collect(Collectors.summarizingLong(Long::longValue));
  6.   final StringBuilder sb = new StringBuilder();
  7.   sb.append("Node Responses for ").append(response.getMethod()).append(" ").append(response.getURIPath()).append(" (Request ID ").append(response.getRequestIdentifier()).append("):\n");
  8.   for (final NodeIdentifier node : response.getNodesInvolved()) {
  9.     sb.append(node).append(": ").append(response.getNodeResponse(node).getRequestDuration(TimeUnit.MILLISECONDS)).append(" millis\n");
  10.   }
  11.   logger.debug("For {} {} (Request ID {}), minimum response time = {}, max = {}, average = {} ms",
  12.       response.getMethod(), response.getURIPath(), response.getRequestIdentifier(), stats.getMin(), stats.getMax(), stats.getAverage());
  13.   logger.debug(sb.toString());
  14. }

代码示例来源：origin: aol/cyclops

  1. default LongSummaryStatistics longStats(ToLongFunction<T> fn){
  2.   return stream().collect(Collectors.summarizingLong(fn));
  3. }
  4. default IntSummaryStatistics intStats(ToIntFunction<T> fn){

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

  1. /**
  2.  * Logs information about the {@link TupleWindow}.
  3.  *
  4.  * @param window The tuple window.
  5.  */
  6. private void log(TupleWindow window) {
  7.  // summarize the newly received tuples
  8.  LongSummaryStatistics received = window.get()
  9.      .stream()
  10.      .map(tuple -> getField(TIMESTAMP_TUPLE_FIELD, tuple, Long.class))
  11.      .collect(Collectors.summarizingLong(Long::longValue));
  12.  LOG.debug("Tuple(s) received; count={}, min={}, max={}, range={} ms",
  13.      received.getCount(),
  14.      received.getMin(),
  15.      received.getMax(),
  16.      received.getMax() - received.getMin());
  17.  if (window.getExpired().size() > 0) {
  18.   // summarize the expired tuples
  19.   LongSummaryStatistics expired = window.getExpired()
  20.       .stream()
  21.       .map(tuple -> getField(TIMESTAMP_TUPLE_FIELD, tuple, Long.class))
  22.       .collect(Collectors.summarizingLong(Long::longValue));
  23.   LOG.debug("Tuple(s) expired; count={}, min={}, max={}, range={} ms, lag={} ms",
  24.       expired.getCount(),
  25.       expired.getMin(),
  26.       expired.getMax(),
  27.       expired.getMax() - expired.getMin(),
  28.       received.getMin() - expired.getMin());
  29.  }
  30. }

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

  1. public LongSummaryStatistics getStatistics() {
  2.     return this.events.stream().
  3.         collect(Collectors.summarizingLong(TodoChangedEvent::getPriority));
  4.   }
  5. }

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

  1. public LongSummaryStatistics getStatistics() {
  2.     return this.events.stream().
  3.         collect(Collectors.summarizingLong(TodoServiceMethodInvokedEvent::getDuration));
  4.   }
  5. }

代码示例来源：origin: sing-group/GC4S

  1. protected String getLongColumnSummary(TableModel model, int columnModel) {
  2.   List<Long> values = new LinkedList<>();
  3.   for (int row = 0; row < model.getRowCount(); row++) {
  4.     values.add((Long) model.getValueAt(row, columnModel));
  5.   }
  6.   LongSummaryStatistics statistics = values.stream()
  7.     .collect(Collectors.summarizingLong(Long::longValue));
  8.   return getSummary("integer", new SummaryStatistics(statistics));
  9. }

代码示例来源：origin: hazelcast/hazelcast-jet-code-samples

  1. public static void main(String[] args) throws Exception {
  2.   // Warmup
  3.   measure();
  4.   measure();
  5.   measure();
  6.   List<Long> timings = new ArrayList<>();
  7.   for (int i = 0; i < 9; i++) {
  8.     timings.add(measure());
  9.     System.gc();
  10.   }
  11.   System.out.println(timings.stream().collect(summarizingLong(x -> x)));
  12. }

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

  1. /**
  2. * Verify if startStreamCut comes before endStreamCut.
  3. */
  4. private void verifyStartAndEndStreamCuts(final StreamCut startStreamCut, final StreamCut endStreamCut) {
  5.   final Map<Segment, Long> startPositions = startStreamCut.asImpl().getPositions();
  6.   final Map<Segment, Long> endPositions = endStreamCut.asImpl().getPositions();
  7.   //check offsets for overlapping segments.
  8.   startPositions.keySet().stream().filter(endPositions::containsKey)
  9.         .forEach(s -> Preconditions.checkArgument(startPositions.get(s) <= endPositions.get(s),
  10.             "Segment offset in startStreamCut should be <= segment offset in endStreamCut."));
  11.   val fromSCSummary = startPositions.keySet()
  12.                    .stream().collect(summarizingLong(Segment::getSegmentId));
  13.   val toSCSummary = endPositions.keySet()
  14.                  .stream().collect(summarizingLong(Segment::getSegmentId));
  15.   Preconditions.checkArgument(fromSCSummary.getMin() <= toSCSummary.getMin(),
  16.       "Start stream cut must precede end stream cut.");
  17.   Preconditions.checkArgument(fromSCSummary.getMax() <= toSCSummary.getMax(),
  18.       "Start stream cut must precede end stream cut.");
  19. }

代码示例来源：origin: com.oath.cyclops/cyclops

  1. default LongSummaryStatistics longStats(ToLongFunction<T> fn){
  2.   return stream().collect(Collectors.summarizingLong(fn));
  3. }
  4. default IntSummaryStatistics intStats(ToIntFunction<T> fn){

代码示例来源：origin: zalando-incubator/catwatch

  1. .flatMap(Set::stream)
  2. .collect(groupingBy(Map.Entry::getKey,
  3.     summarizingLong(entry -> ((Number) ((Map.Entry) entry).getValue()).longValue())));

代码示例来源：origin: hazelcast/hazelcast-jet-code-samples

  1. private void go() throws Exception {
  2.   List<Long> timings = new ArrayList<>();
  3.   try {
  4.     setup();
  5.     // Warmup
  6.     measure();
  7.     measure();
  8.     measure();
  9.     for (int i = 0; i < 9; i++) {
  10.       timings.add(measure());
  11.       System.gc();
  12.     }
  13.   } finally {
  14.     Jet.shutdownAll();
  15.   }
  16.   System.out.println(timings.stream().collect(summarizingLong(x -> x)));
  17. }

代码示例来源：origin: xiancloud/xian

  1. LongSummaryStatistics intSummaryStatistics = consumeTimes.stream().collect(Collectors.summarizingLong(value -> value));

代码示例来源：origin: xiancloud/xian

  1. LongSummaryStatistics intSummaryStatistics = consumeTimes.stream().collect(Collectors.summarizingLong(value -> value));

代码示例来源：origin: Netflix/spectator

  1. @Test
  2. public void distributionSummaries() {
  3.  Registry r = newRegistry(true, 10000);
  4.  r.distributionSummary("foo").record(1L);
  5.  r.distributionSummary("foo", "a", "1", "b", "2").record(1L);
  6.  r.distributionSummary("foo", "a", "1", "b", "3").record(13L);
  7.  r.distributionSummary("foo", "a", "1", "b", "2").record(1L);
  8.  r.distributionSummary("bar", "a", "1", "b", "2").record(1L);
  9.  Assertions.assertEquals(4, r.distributionSummaries().count());
  10.  final LongSummaryStatistics countSummary = r.distributionSummaries()
  11.    .filter(Functions.nameEquals("foo"))
  12.    .collect(Collectors.summarizingLong(DistributionSummary::count));
  13.  Assertions.assertEquals(3L, countSummary.getCount());
  14.  Assertions.assertEquals(4L, countSummary.getSum());
  15.  Assertions.assertEquals(2L, countSummary.getMax());
  16.  final LongSummaryStatistics totalSummary = r.distributionSummaries()
  17.    .filter(Functions.nameEquals("foo"))
  18.    .collect(Collectors.summarizingLong(DistributionSummary::totalAmount));
  19.  Assertions.assertEquals(3L, totalSummary.getCount());
  20.  Assertions.assertEquals(16L, totalSummary.getSum());
  21.  Assertions.assertEquals(13L, totalSummary.getMax());
  22. }

代码示例来源：origin: Netflix/spectator

  1. @Test
  2. public void timers() {
  3.  Registry r = newRegistry(true, 10000);
  4.  r.timer("foo").record(1L, TimeUnit.NANOSECONDS);
  5.  r.timer("foo", "a", "1", "b", "2").record(1L, TimeUnit.NANOSECONDS);
  6.  r.timer("foo", "a", "1", "b", "3").record(13L, TimeUnit.NANOSECONDS);
  7.  r.timer("foo", "a", "1", "b", "2").record(1L, TimeUnit.NANOSECONDS);
  8.  r.timer("bar", "a", "1", "b", "2").record(1L, TimeUnit.NANOSECONDS);
  9.  Assertions.assertEquals(4, r.timers().count());
  10.  final LongSummaryStatistics countSummary = r.timers()
  11.    .filter(Functions.nameEquals("foo"))
  12.    .collect(Collectors.summarizingLong(Timer::count));
  13.  Assertions.assertEquals(3L, countSummary.getCount());
  14.  Assertions.assertEquals(4L, countSummary.getSum());
  15.  Assertions.assertEquals(2L, countSummary.getMax());
  16.  final LongSummaryStatistics totalSummary = r.timers()
  17.    .filter(Functions.nameEquals("foo"))
  18.    .collect(Collectors.summarizingLong(Timer::totalTime));
  19.  Assertions.assertEquals(3L, totalSummary.getCount());
  20.  Assertions.assertEquals(16L, totalSummary.getSum());
  21.  Assertions.assertEquals(13L, totalSummary.getMax());
  22. }

代码示例来源：origin: Netflix/spectator

  1. @Test
  2. public void counters() {
  3.  Registry r = newRegistry(true, 10000);
  4.  r.counter("foo").increment();
  5.  r.counter("foo", "a", "1", "b", "2").increment();
  6.  r.counter("foo", "a", "1", "b", "3").increment(13L);
  7.  r.counter("foo", "a", "1", "b", "2").increment();
  8.  r.counter("bar", "a", "1", "b", "2").increment();
  9.  Assertions.assertEquals(4, r.counters().count());
  10.  final LongSummaryStatistics summary = r.counters()
  11.    .filter(Functions.nameEquals("foo"))
  12.    .collect(Collectors.summarizingLong(Counter::count));
  13.  Assertions.assertEquals(3L, summary.getCount());
  14.  Assertions.assertEquals(16L, summary.getSum());
  15.  Assertions.assertEquals(13L, summary.getMax());
  16. }

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

Collectors

相关文章

    查看更多

    热门标签

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

    最新文章

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