java - 如何在滑动窗口中获取当前窗口时间？

Question

我正在使用 Storm 实现的滑动窗口:

From Here

这是我的拓扑:

 public static void main(String[] args) throws Exception {
    TopologyBuilder builder = new TopologyBuilder();

    builder.setSpout("rabbitSpout", new RabbitMQSpout());
    builder.setBolt("filterBolt", new FilteringBolt()).shuffleGrouping("rabbitSpout");

    builder.setBolt("HourStatisticsBolt", new SlidingWindowStatisticsBolt()
            .withWindow(new BaseWindowedBolt.Duration(60, TimeUnit.MINUTES),
                    new BaseWindowedBolt.Duration(10, TimeUnit.SECONDS))
            .withTimestampField("timestamp")).shuffleGrouping("filterBolt");

在我的 SlidingWindowStatisticsBolt 的执行方法中，我想获取窗口开始或结束的时间戳。在我的 bolt 中，如何获得窗口长度和滑动持续时间？

Answer 1

由于您使用的是事件时间 (withTimestampField)，因此窗口是根据周期性水印计算的。现在，窗口开始/结束时间未在 TupleWindow 中公开。

在 Storm 的最新主分支中，TupleWindow有一个 getTimestamp 方法，它返回窗口结束时间戳，适用于基于处理和事件时间的窗口。这将在 Storm 的 future 版本(2.0 版本)中提供。如果您希望向后移植并在下一个 1.x 版本中提供此功能，您可以提交 JIRA here