Flink 做传统的大数据项目

问题遇到的现象和发生背景

我现在做一个传统大数据的项目，架构师说用flink做批流一体，但我一头雾水，有啥例子没有，比如有项目实战的用Flink的，能加一下你不，谢谢！

问题相关代码，请勿粘贴截图

运行结果及报错内容

我的解答思路和尝试过的方法

我想要达到的结果

最好看一下官方文档：

基于 DataStream API 实现欺诈检测 | Apache Flink 基于 DataStream API 实现欺诈检测 # Apache Flink 提供了 DataStream API 来实现稳定可靠的、有状态的流处理应用程序。 Flink 支持对状态和时间的细粒度控制，以此来实现复杂的事件驱动数据处理系统。 这个入门指导手册讲述了如何通过 Flink DataStream API 来实现一个有状态流处理程序。你要搭建一个什么系统 # 在当今数字时代，信用卡欺诈行为越来越被重视。 罪犯可以通过诈骗或者入侵安全级别较低系统来盗窃信用卡卡号。 用盗得的信用卡进行很小额度的例如一美元或者更小额度的消费进行测试。 如果测试消费成功，那么他们就会用这个信用卡进行大笔消费，来购买一些他们希望得到的，或者可以倒卖的财物。在这个教程中，你将会建立一个针对可疑信用卡交易行为的反欺诈检测系统。 通过使用一组简单的规则，你将了解到 Flink 如何为我们实现复杂业务逻辑并实时执行。准备条件 # 这个代码练习假定你对 Java 或 Scala 有一定的了解，当然，如果你之前使用的是其他开发语言，你也应该能够跟随本教程进行学习。在 IDE 中运行 # 在 IDE 中运行该项目可能会遇到 java.langNoClassDefFoundError 的异常。这很可能是因为运行所需要的 Flink 的依赖库没有默认被全部加载到类路径（classpath）里。IntelliJ IDE：前往 运行 > 编辑配置 > 修改选项 > 选中 将带有 “provided” 范围的依赖项添加到类路径。这样的话，运行配置将会包含所有在 IDE 中运行所必须的类。困难求助 # 如果遇到困难，可以参考 社区支持资源。 当然也可以在邮件列表提问，Flink 的 用户邮件列表 一直被评为所有Apache项目中最活跃的一个，这也是快速获得帮助的好方法。 https://nightlies.apache.org/flink/flink-docs-release-1.15/zh/docs/try-flink/datastream/

你们对实时是有硬性要求吗，如果不必要的话用spark也挺好的，博客里面都是简单的，没啥帮助，你可以看看尚硅谷的大数据flink实时项目，我之前看的感觉可以