也许在你的电脑里有类似伪代码的东西 reduce() 方法：

long lastDate = 0;
V lastValue = null;

for (V value : values) {
    currentDate = parseDateIntoMillis(value);
    if (lastValue != null) {
        context.write(key, lastValue.toString() + "," + (currentDate - lastDate));
    }
    lastDate = currentDate;
    lastValue = value;
}
context.write(key, lastValue.toString() + "," + 0);

显然会有整理工作要做，但总的想法是相当简单的。
请注意，由于需要将下一个值的日期作为当前值计算的一部分，因此通过值的迭代会跳过第一次写入，因此在循环之后会进行额外的写入，以确保所有值都被考虑在内。
如果你有什么问题，尽管问吧。

您可以通过以下代码

reduce (LongWritable key, Iterable<String> Values, context){
  Date currentDate = null;
  LongWritable  diff = new LongWritable();

 for (String value : values) {
    Date nextDate = new Date(value.toString().split(",")[3]);
    if (currentDate != null) {
        diff.set(Math.abs(nextDate.getTime()-currentDate.getTime())/1000)
        context.write(key, diff);
    }
    currentDate = nextDate;
}

}