如何使用Java8流获得最后一个元素和第一个元素的值之间的差异？

Question

DateTime,Value
...
1470012671,618.59
1470012912,618.62
1470013212,618.65
1470013512,618.68
1470013632,618.69
1470013900,618.71
...

startMillis: 1470012800
endMillis: 1470013800

618.69 - 618.62 = 0.07

double amountKiloWattHours = 0;
long startMillis = startingTime.toEpochSecond();
long endMillis = startMillis + PERIOD_LENGTH_MILLIS;
try (Stream<String> stream = Files.lines(Paths.get(fileName))) {
        // Currently, only returns all pairs within range...
    Stream<Pair> pairs = stream
        .skip(1)
        .map(p -> {
            return new Pair(p);
        })
        .filter(pair -> {
            return (pair.getMillis() > startMillis) && (pair.getMillis() < endMillis);
       });
} catch (Exception e) {
    // TODO specify and handle exceptions...
}

public class Pair {
    @Getter
    private final long millis;
    @Getter
    private final double kWhs;

    public Pair(String input) {
        String[] parts = input.split(",");
        this.millis = Long.parseLong(parts[0]);
        this.kWhs = Double.parseDouble(parts[1]);
    }
}

额外的问题：我如何得到插值的结果，其中确切的时间戳的值是线性插值之间的两个周围的值？

Answer 1

没有现成的收集器可以同时找到最大和最小元素，但是您可以使用我在本答案中编写的pairing收集器（它在我的StreamEx库中很容易获得--参见JavaDoc）：

Comparator<Pair> cmp = Comparator.comparingLong(Pair::getMillis);

double diff = stream
    .skip(1)
    .map(Pair::new)
    .filter(pair -> (pair.getMillis() > startMillis) && (pair.getMillis() < endMillis))
    .collect(pairing(Collectors.maxBy(cmp), Collectors.minBy(cmp),
      (maxPair, minPair) -> maxPair.get().getKWhs() - minPair.get().getKWhs()));

这将不会收集不必要的数据：您将只提取最小和最大行。

注意：此代码假设至少有一个对（即范围内有一个时间戳/值实例，不一定同时有不同的最小时间戳/值和最大时间戳/值）满足条件。如果您想特别处理没有这样的对的情况（例如，返回0)，您应该修改代码（例如，像这样:maxpair.map(pair::getKWHs).orelse(0d)-minpair.map(pair::getKWHs).orelse(0d))。