Flink_CEP_4步骤

末蓝、 2022-11-22 00:12 173阅读 0赞

*  1.首先定义一个匹配的序列模式
 *  2.将pattern应用在数据流上
 *  3.定义一个测输出流标签，用来标明超时事件的测输出流
 *  4.调用select方法，提取匹配事件和超时事件，分别进行处理转换输出  
    自定义超时时间继承PatternTimeoutFunction  
    自定义匹配处理函数PatternSelectFunction

//1.定义一个匹配事件序列的模式
        val orderPayPattern = Pattern
          .begin[OrderEvent]("create").where(_.eventType == "create")  //首先是订单的create事件
          .followedBy("pay").where(_.eventType == "pay") //后面来的是订单的pay事件
          .within(Time.minutes(15))
    
        //2.将pattern应用在按照orderId分组的数据流上
        val patterStream = CEP.pattern(orderEventStream.keyBy(_.orderId), orderPayPattern)
    
        //3.定义一个测输出流标签，用来标明超时事件的测输出流
        val orderTimeOutputTag = new OutputTag[OrderResult]("order time out")
    
        //4.调用select方法，提取匹配事件和超时事件，分别进行处理转换输出
        val result = patterStream
          .select(orderTimeOutputTag, new OrderTimeOutSelect(), new OrderPaySelect())

如果没看懂，提供一个案列  
[https://blog.csdn.net/qq\_46548855/article/details/109462736][https_blog.csdn.net_qq_46548855_article_details_109462736]  
Flink官网CEP  
[https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/libs/cep.html][https_ci.apache.org_projects_flink_flink-docs-release-1.11_dev_libs_cep.html]

[https_blog.csdn.net_qq_46548855_article_details_109462736]: https://blog.csdn.net/qq_46548855/article/details/109462736
[https_ci.apache.org_projects_flink_flink-docs-release-1.11_dev_libs_cep.html]: https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/libs/cep.html

发表评论取消回复

表情：

评论列表（有 0 条评论，173人围观）

还没有评论，来说两句吧...

相关阅读

相关 neo4j下载安装配置步骤

目录一、介绍简介 Neo4j和JDK版本对应二、下载官网下载直接获取三、解压缩安装四、配置环境变量五、启动测试 -------------

心已赠人/ 2023年10月16日 08:44/ 0 赞/ 58 阅读

相关基于Flinkcep-1.11.2 动态规则修改实践

1，事先说明这个代码搞出来说白了就是在大佬的代码参考下完成的，之前就一直想搞 cep规则动态修改，苦于对cep的源码不熟悉，没法下手。之前有个大佬搞过基于flin

快来打我*/ 2022年12月27日 09:25/ 0 赞/ 549 阅读

相关 18 模块划分4步骤——EDD

模块划分思路自顶向下：水平切分思路——分层。垂直切分思路——功能模块。自底向上：先识别类、后归纳出模块的思路——用例驱动。拍脑袋：需要大

男娘i/ 2022年11月27日 07:24/ 0 赞/ 395 阅读

相关 Flink_CEP_4步骤

1.首先定义一个匹配的序列模式 2.将pattern应用在数据流上 3.定义一个测输出流标签，用来标明超时事件的测输出流 4.调用select方法，提取

末蓝、/ 2022年11月22日 00:12/ 0 赞/ 174 阅读

相关移植Andorid4.0.4 - 步骤及问题汇总

\+ 华清远见 - MichaelTang \--------------------------------------------------------------

逃离我推掉我的手/ 2022年06月10日 10:18/ 0 赞/ 129 阅读

相关 python3.4安装scrapy的步骤

在安装前可以使用 python -m pip install --upgrade pip 升级一下pip ![70][] 1.安装wheel 使用命令 pip in

﹏ヽ暗。殇╰゛Y/ 2022年05月10日 03:26/ 0 赞/ 278 阅读

相关 jumpserver4.0centos7安装步骤

[jumpserver4.0centos7安装步骤][jumpserver4.0centos7] 一步一步安装(CentOS) 测试推荐环境 CPU:

向右看齐/ 2022年04月24日 04:58/ 0 赞/ 150 阅读

相关 CentOS7.4 安装JDK 步骤

1.先在官网下载jdk1.8的压缩文件 2.用putty将压缩文件拷到home目录下 3.新建一个/home/jdk1.8目录： mkdir /home/jdk1.8

秒速五厘米/ 2022年04月17日 05:26/ 0 赞/ 247 阅读

相关 Mongodb -- mongodb4.0以上安装步骤

[https://www.cnblogs.com/whowhere/p/9637605.html][https_www.cnblogs.com_whowhere_p_96376

短命女/ 2022年04月11日 03:16/ 0 赞/ 248 阅读

相关 Ionic4 项目打包Android App步骤

1. 安装 Nodejs 说明：安装完成 nodejs的版本后，如果npm 不是最新版本, 运行 `npm install npm` 升级成最新的 npm 2.

港控/mmm°/ 2021年12月11日 09:29/ 0 赞/ 402 阅读