CEP 如何按事件时间处理

[bulterman]

Hi all,
我写了一个测试demo，设置了水印从数据中提取，但在cep的pattern里within()还是按processing time而不是event time来触发？

[huang botao]

你好，Flink 默认按照ProcessingTime 来处理数据，

如果想修改的话，可以可以通过`env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);`
的方式来设置 按照 EventTime 来处理数据。

在CEP中也是通过一样的方法来设置时间处理方式。


On Wed, Jan 6, 2021 at 7:58 PM bulterman <[hidden email]> wrote:

> Hi all,
> 我写了一个测试demo，设置了水印从数据中提取，但在cep的pattern里within()还是按processing time而不是event
> time来触发？