[大数据]Flink CEP 简单例子

1、引入依赖（注意版本要和flink版本一致，例子暂用1.12版本）

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-cep_2.11</artifactId>
    <version>1.12.7</version>
</dependency>

2、定义传递类

package com.test;

import java.util.Date;


public class Student {


    private Integer num;
    private String name;
    private Date time;


    public Integer getNum() {
        return num;
    }

    public void setNum(Integer num) {
        this.num = num;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public Date getTime() {
        return time;
    }

    public void setTime(Date time) {
        this.time = time;
    }

    @Override
    public boolean equals(Object o) {
        if (this == o) return true;
        if (!(o instanceof Stud

了解本专栏 订阅专栏 解锁全文 学习会员免费看 赠一年