Re: CEP 如何按事件时间处理

2021-01-10 文章 huang botao
你好，Flink 默认按照ProcessingTime 来处理数据， 如果想修改的话，可以可以通过`env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);` 的方式来设置 按照 EventTime 来处理数据。 在CEP中也是通过一样的方法来设置时间处理方式。 On Wed, Jan 6, 2021 at 7:58 PM bulterman <15618338...@163.com> wrote: > Hi all, > 我写了一个测试demo，设置了水印从数据中提取，但在cep的pattern里within()

CEP 如何按事件时间处理

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