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