信用卡欺诈检测
在本案例中，我们将构建一个用于对可疑信用卡交易发出警报的欺诈检测系统。通过使用一组简单的规则，Flink可以实现高级业务逻辑和实时操作。
主要内容包括：
实际应用中，数据源将来自外部系统(如Apache Kafka、Rabbit MQ或Apache Pulsar)的数据导入到Flink作业中。而在本案例中，我们将创建一个自定义的数据源，用来模拟生成信用卡交易数据流。该源生成一个无限的信用卡交易流供流程序处理，每个交易包含一个帐户ID (accountId)、事务发生时的时间戳(timestamp)和交易金额(amount)。而附加到源的name只是为了调试目的，所以如果出现错误，我们就知道错误来自何处。
交易流包含来自大量用户的交易数据，因此它需要在多个欺诈检测任务中并行处理。由于欺诈发生在每个帐户的基础上，所以必须确保相同帐户的所有交易都由欺诈检测操作符的相同并行任务处理。
数据源
定义信用卡交易事件类Transaction，代码实现如下：
import java.io.Serializable;
import java.util.Objects;
/**
*
* 实体类，代表信用卡交易
*/ ......
......
抱歉，只有登录会员才可浏览！会员登录
