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

DoubleStream.filter介绍

[英]Returns a stream consisting of the elements of this stream that match the given predicate.

This is an intermediate operation.
[中]返回一个流，该流包含与给定谓词匹配的该流元素。
这是一个intermediate operation。

代码示例

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

public DoubleFilterAction(DoublePredicate predicate) {
  super(s -> s.filter(requireNonNull(predicate)), DoubleStream.class, FILTER);
}

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

private int fragmentedCpu() {
  Double res = nodeIdToResources.get().values().parallelStream().filter(this::isFragmented)
                 .mapToDouble(SupervisorResources::getAvailableCpu).filter(x -> x > 0).sum();
  return res.intValue();
}

代码示例来源：origin: stackoverflow.com

double[] d = {8, 7, -6, 5, -4};
d = Arrays.stream(d).filter(x -> x > 0).toArray();
//d => [8, 7, 5]

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

private double fragmentedMemory() {
  Double res = nodeIdToResources.get().values().parallelStream().filter(this::isFragmented)
                 .mapToDouble(SupervisorResources::getAvailableMem).filter(x -> x > 0).sum();
  return res.intValue();
}

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

@Override
  public DoubleStream build(boolean parallel) {
    return previous().build(parallel).filter(predicate);
  }
}

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

@Override
public DoubleStream filter(DoublePredicate predicate) {
  return wrap(stream().filter(predicate));
}

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

/**
 * Get new statistics that excludes values beyond mean +/- 2 * stdev
 *
 * @param data Source data
 * @return new {@link @DescriptiveStatistics objects with sanitized data}
 */
private static DescriptiveStatistics sanitize(@NotNull DescriptiveStatistics data) {
 double meanValue = data.getMean();
 double delta = MARGIN * meanValue;
 double minVal = meanValue - delta;
 double maxVal = meanValue + delta;
 return new DescriptiveStatistics(Arrays.stream(data.getValues())
   .filter(x -> x > minVal && x < maxVal)
   .toArray());
}

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

@Deprecated //moved to cyclops.companion.Functions
public static Function<? super ReactiveSeq<Double>, ? extends ReactiveSeq<Double>> filterLongs(DoublePredicate b){
  return a->a.doubles(i->i,s->s.filter(b));
}
/*

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

public static Function<? super ReactiveSeq<Double>, ? extends ReactiveSeq<Double>> filterLongs(DoublePredicate b){
  return a->a.doubles(i->i,s->s.filter(b));
}
/*

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

@Test
public void doubles(){
  assertThat(ReactiveSeq.range(1, 1000).doubles(i->i.doubleValue(),s->s.map(i->i*2).filter(i->i<500))
             .size(),equalTo(249));
}
@Test

代码示例来源：origin: stackoverflow.com

private static double roundLambda(double n, double[] a) {
  double[] r = {0}, d = {Double.MAX_VALUE};
  Arrays.stream(a).filter((i)->Math.abs(i-n)<d[0]).forEach(i->{d[0]=Math.abs(i-n);r[0]=i;});
  return r[0];
}

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

@Deprecated //moved to cyclops.companion.Functions
public static Function<? super ReactiveSeq<Double>, ? extends ReactiveSeq<Double>> filterLongs(DoublePredicate b){
  return a->a.doubles(i->i,s->s.filter(b));
}
/*

代码示例来源：origin: org.apache.plc4x/plc4j-scraper

@Override
public double evaluate(double[] values) throws MathIllegalArgumentException {
  long below = Arrays.stream(values)
    .filter(val -> val <= threshold)
    .count();
  return (double) below / values.length;
}

代码示例来源：origin: Rsl1122/Plan-PlayerAnalytics

public double averageRAM() {
  return tpsData.stream()
      .mapToDouble(TPS::getUsedMemory)
      .filter(num -> num >= 0)
      .average().orElse(-1);
}

代码示例来源：origin: Rsl1122/Plan-PlayerAnalytics

public double averageCPU() {
  return tpsData.stream()
      .mapToDouble(TPS::getCPUUsage)
      .filter(num -> num >= 0)
      .average().orElse(-1);
}

代码示例来源：origin: Rsl1122/Plan-PlayerAnalytics

public double averageEntities() {
  return tpsData.stream()
      .mapToDouble(TPS::getEntityCount)
      .filter(num -> num >= 0)
      .average().orElse(-1);
}

代码示例来源：origin: Rsl1122/Plan-PlayerAnalytics

public double averageFreeDisk() {
  return tpsData.stream()
      .mapToDouble(TPS::getFreeDiskSpace)
      .filter(num -> num >= 0)
      .average().orElse(-1);
}

代码示例来源：origin: Rsl1122/Plan-PlayerAnalytics

public double average() {
    return pings.stream().mapToDouble(Ping::getAverage)
        .filter(value -> value > 0 && value <= 4000)
        .average().orElse(-1);
  }
}

代码示例来源：origin: org.apache.plc4x/plc4j-scraper

@Override
public double evaluate(double[] values, int begin, int length) throws MathIllegalArgumentException {
  long below = IntStream.range(begin, length)
    .mapToDouble(i -> values[i])
    .filter(val -> val > threshold)
    .count();
  return 100.0 * below / length;
}

代码示例来源：origin: com.simiacryptus/java-util

/**
 * Gets volume.
 *
 * @return the volume
 */
public double getVolume() {
 int dim = min.length;
 return IntStream.range(0, dim).mapToDouble(d -> {
  return max[d] - min[d];
 }).filter(x -> Double.isFinite(x) && x > 0.0).reduce((a, b) -> a * b).orElse(Double.NaN);
}