如何在模式不匹配的情况下发出输出



Flink的CEP库是否可以根据接收到的每个输入发出数据?即使没有任何匹配的模式?例如,假设有这种模式

pattern: ba
input stream: a b a a
expect output stream is: F F T F

默认行为如下:

_ _ T _ 
_ = times that there is not any output.

我想到的最简单的解决方案是将输入与输出流连接(flink中的流上没有任何左连接,我应该通过coFlatMap进行准备(,并映射到输出(用值更改Nones并删除输入(,但我不知道这是否是一个好的解决方案(性能方面(。

您可以使用union[1]将输入(或输入的转换版本(与来自CEP的结果进行组合。请注意,为了实现这一点,所有被统一的数据流都必须具有相同的类型。

[1]https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/datastream/operators/overview/#union

相关内容

  • 没有找到相关文章

最新更新