谷歌云数据流 - 我可以从元数据中获取“事件时间”吗？

Question

问候开发者，

我知道数据流（DF）可以从 I/O（如 Pubsub）获取事件时间，我也可以将“事件时间”分配给数据。但是，我可以从数据中获取这个属性值吗？

据我了解，我可以从数据中获取输入时间戳（处理时间），但不能获取事件时间。

Q1：我可以从数据中获取事件时间吗？

Q2：如果可以，如何获得？

感谢您的帮助：D

Answer 1

要获取 DoFn 中元素的时间戳，您可以调用 ProcessContext.timestamp()。要根据自己的应用逻辑设置元素的时间戳，可以使用Context.outputWithTimestamp()。

像这样：

@Override
public void processElement(ProcessContext c) {
  // Generate a timestamp that falls somewhere in two hours after the event time.
  long randMillis = (long) (Math.random() * Duration.standardHours(2).getMillis());
  Instant randomTimestamp = c.timestamp().plus(randMillis);
  c.outputWithTimestamp(c.element(), new Instant(randomTimestamp));
}