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

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

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

Collectors.summarizingDouble介绍

暂无

代码示例

代码示例来源:origin: goldmansachs/gs-collections

  1. @Benchmark
  2. public Map<Product, DoubleSummaryStatistics> aggregateByProduct_serial_lazy_jdk()
  3. {
  4. Map<Product, DoubleSummaryStatistics> result =
  5. this.jdkPositions.stream().collect(
  6. Collectors.groupingBy(
  7. Position::getProduct,
  8. Collectors.summarizingDouble(Position::getMarketValue)));
  9. Assert.assertNotNull(result);
  10. return result;
  11. }

代码示例来源:origin: goldmansachs/gs-collections

  1. @Benchmark
  2. public Map<Account, DoubleSummaryStatistics> aggregateByAccount_serial_lazy_jdk()
  3. {
  4. Map<Account, DoubleSummaryStatistics> accountDoubleMap =
  5. this.jdkPositions.stream().collect(
  6. Collectors.groupingBy(
  7. Position::getAccount,
  8. Collectors.summarizingDouble(Position::getMarketValue)));
  9. Assert.assertNotNull(accountDoubleMap);
  10. return accountDoubleMap;
  11. }

代码示例来源:origin: goldmansachs/gs-collections

  1. @Benchmark
  2. public Map<String, DoubleSummaryStatistics> aggregateByCategory_serial_lazy_jdk()
  3. {
  4. Map<String, DoubleSummaryStatistics> categoryDoubleMap =
  5. this.jdkPositions.stream().collect(
  6. Collectors.groupingBy(
  7. Position::getCategory,
  8. Collectors.summarizingDouble(Position::getMarketValue)));
  9. Assert.assertNotNull(categoryDoubleMap);
  10. return categoryDoubleMap;
  11. }

代码示例来源:origin: goldmansachs/gs-collections

  1. @Benchmark
  2. public Map<String, DoubleSummaryStatistics> aggregateByCategory_serial_lazy_streams_gsc()
  3. {
  4. Map<String, DoubleSummaryStatistics> categoryDoubleMap =
  5. this.gscPositions.stream().collect(
  6. Collectors.groupingBy(
  7. Position::getCategory,
  8. Collectors.summarizingDouble(Position::getMarketValue)));
  9. Assert.assertNotNull(categoryDoubleMap);
  10. return categoryDoubleMap;
  11. }

代码示例来源:origin: goldmansachs/gs-collections

  1. @Benchmark
  2. public Map<Account, DoubleSummaryStatistics> aggregateByAccount_parallel_lazy_jdk()
  3. {
  4. Map<Account, DoubleSummaryStatistics> result =
  5. this.jdkPositions.parallelStream().collect(
  6. Collectors.groupingBy(
  7. Position::getAccount,
  8. Collectors.summarizingDouble(Position::getMarketValue)));
  9. Assert.assertNotNull(result);
  10. return result;
  11. }

代码示例来源:origin: goldmansachs/gs-collections

  1. @Benchmark
  2. public Map<Account, DoubleSummaryStatistics> aggregateByAccount_parallel_lazy_streams_gsc()
  3. {
  4. Map<Account, DoubleSummaryStatistics> result =
  5. this.gscPositions.parallelStream().collect(
  6. Collectors.groupingBy(
  7. Position::getAccount,
  8. Collectors.summarizingDouble(Position::getMarketValue)));
  9. Assert.assertNotNull(result);
  10. return result;
  11. }

代码示例来源:origin: goldmansachs/gs-collections

  1. @Benchmark
  2. public Map<String, DoubleSummaryStatistics> aggregateByCategory_parallel_lazy_streams_gsc()
  3. {
  4. Map<String, DoubleSummaryStatistics> result =
  5. this.gscPositions.parallelStream().collect(
  6. Collectors.groupingBy(Position::getCategory, Collectors.summarizingDouble(Position::getMarketValue)));
  7. Assert.assertNotNull(result);
  8. return result;
  9. }

代码示例来源:origin: goldmansachs/gs-collections

  1. @Benchmark
  2. public Map<Account, DoubleSummaryStatistics> aggregateByAccount_serial_lazy_streams_gsc()
  3. {
  4. Map<Account, DoubleSummaryStatistics> accountDoubleMap =
  5. this.gscPositions.stream().collect(
  6. Collectors.groupingBy(
  7. Position::getAccount,
  8. Collectors.summarizingDouble(Position::getMarketValue)));
  9. Assert.assertNotNull(accountDoubleMap);
  10. return accountDoubleMap;
  11. }

代码示例来源:origin: goldmansachs/gs-collections

  1. @Benchmark
  2. public Map<Product, DoubleSummaryStatistics> aggregateByProduct_parallel_lazy_jdk()
  3. {
  4. Map<Product, DoubleSummaryStatistics> result =
  5. this.jdkPositions.parallelStream().collect(
  6. Collectors.groupingBy(
  7. Position::getProduct,
  8. Collectors.summarizingDouble(Position::getMarketValue)));
  9. Assert.assertNotNull(result);
  10. return result;
  11. }

代码示例来源:origin: goldmansachs/gs-collections

  1. @Benchmark
  2. public Map<Product, DoubleSummaryStatistics> aggregateByProduct_serial_lazy_streams_gsc()
  3. {
  4. Map<Product, DoubleSummaryStatistics> result =
  5. this.gscPositions.stream().collect(
  6. Collectors.groupingBy(
  7. Position::getProduct,
  8. Collectors.summarizingDouble(Position::getMarketValue)));
  9. Assert.assertNotNull(result);
  10. return result;
  11. }

代码示例来源:origin: goldmansachs/gs-collections

  1. @Benchmark
  2. public Map<Product, DoubleSummaryStatistics> aggregateByProduct_parallel_lazy_streams_gsc()
  3. {
  4. Map<Product, DoubleSummaryStatistics> result =
  5. this.gscPositions.parallelStream().collect(
  6. Collectors.groupingBy(
  7. Position::getProduct,
  8. Collectors.summarizingDouble(Position::getMarketValue)));
  9. Assert.assertNotNull(result);
  10. return result;
  11. }

代码示例来源:origin: goldmansachs/gs-collections

  1. @Benchmark
  2. public Map<String, DoubleSummaryStatistics> aggregateByCategory_parallel_lazy_jdk()
  3. {
  4. Map<String, DoubleSummaryStatistics> result =
  5. this.jdkPositions.parallelStream().collect(
  6. Collectors.groupingBy(Position::getCategory, Collectors.summarizingDouble(Position::getMarketValue)));
  7. Assert.assertNotNull(result);
  8. return result;
  9. }

代码示例来源:origin: OryxProject/oryx

  1. .collect(Collectors.summarizingDouble(f -> ((NumericFeature) f).getValue()))
  2. ).collect().stream().map(p -> {

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

  1. default DoubleSummaryStatistics doubleStats(ToDoubleFunction<T> fn){
  2. return stream().collect(Collectors.summarizingDouble(fn));
  3. }

代码示例来源:origin: geotools/geotools

  1. /** Returns min and max value applying the expression over the feature collection */
  2. public static NumberRange<Double> getMinMax(
  3. ListFeatureCollection fc, Expression attributeExpression) {
  4. DoubleSummaryStatistics stats =
  5. fc.stream()
  6. .collect(
  7. Collectors.summarizingDouble(
  8. f -> attributeExpression.evaluate(f, Double.class)));
  9. return new NumberRange<>(Double.class, stats.getMin(), stats.getMax());
  10. }

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

  1. protected String getDoubleListSummary(List<Double> values,
  2. String numericType
  3. ) {
  4. DoubleSummaryStatistics statistics = values.stream()
  5. .collect(Collectors.summarizingDouble(Double::doubleValue));
  6. return getSummary(numericType, new SummaryStatistics(statistics));
  7. }

代码示例来源:origin: kousen/java_8_recipes

  1. public void computeSalaryStatistics() {
  2. List<Team> teams = parseSalaries();
  3. DoubleSummaryStatistics teamStats = teams.stream()
  4. .mapToDouble(Team::getSalary)
  5. .collect(DoubleSummaryStatistics::new,
  6. DoubleSummaryStatistics::accept,
  7. DoubleSummaryStatistics::combine);
  8. printStats(teamStats);
  9. teamStats = teams.stream()
  10. .collect(Collectors.summarizingDouble(Team::getSalary));
  11. printStats(teamStats);
  12. }

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

  1. default DoubleSummaryStatistics doubleStats(ToDoubleFunction<T> fn){
  2. return stream().collect(Collectors.summarizingDouble(fn));
  3. }

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

  1. @Test
  2. public void maxGauge() {
  3. Registry r = newRegistry(true, 10000);
  4. r.maxGauge("foo").set(1.0);
  5. r.maxGauge("foo").set(3.0);
  6. r.maxGauge("foo").set(2.0);
  7. final DoubleSummaryStatistics valueSummary = r.gauges()
  8. .filter(Functions.nameEquals("foo"))
  9. .collect(Collectors.summarizingDouble(Gauge::value));
  10. Assertions.assertEquals(1, valueSummary.getCount());
  11. Assertions.assertEquals(3.0, valueSummary.getSum(), 1e-12);
  12. }

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

  1. @Test
  2. public void gauges() {
  3. Registry r = newRegistry(true, 10000);
  4. r.gauge(r.createId("foo", "a", "1")).set(1.0);
  5. r.gauge(r.createId("foo", "a", "2")).set(2.0);
  6. r.gauge(r.createId("bar")).set(7.0);
  7. Assertions.assertEquals(3, r.gauges().count());
  8. final DoubleSummaryStatistics valueSummary = r.gauges()
  9. .filter(Functions.nameEquals("foo"))
  10. .collect(Collectors.summarizingDouble(Gauge::value));
  11. Assertions.assertEquals(2, valueSummary.getCount());
  12. Assertions.assertEquals(3.0, valueSummary.getSum(), 1e-12);
  13. Assertions.assertEquals(1.5, valueSummary.getAverage(), 1e-12);
  14. }

相关文章