最新 最热

袋鼠云产品功能更新报告01期丨用诚心倾听您的需求

作为一家以 “客户第一” 为价值观的公司,袋鼠云一直以来关注客户体验,专注提升产品品质,不断收集客户反馈,持续增加新功能并不断优化旧功能,为用户输出最佳产品使用体验。2022 年上半年,我们新增了许多重要功能,并进行了若...

2022-09-02
0

【Flink】Flink环境搭建

https://archive.apache.org/dist/flink/flink-1.12.0/flink-1.12.0-bin-scala_2.12.tgz

2022-09-02
0

Flink学习笔记(10) - CEP

一个或多个由简单事件构成的事件流通过一定的规则匹配,然后输出用户想得到的数据 —— 满足规则的复杂事件

2022-09-01
0

Flinkv1.13实现金融反诈骗案例

Apache Flink 提供了 DataStream API 来实现稳定可靠的、有状态的流处理应用程序。 Flink 支持对状态和时间的细粒度控制,以此来实现复杂的事件驱动数据处理系统。 这个入门指导手册讲述了如何通过 Flink DataStream A...

2022-09-01
0

hudi时间旅行查询

hudi每次数据写入时都会生成一个时间戳,用于表示数据写入的时间,基于该特性,在进行数据查询时可使用该时间对hudi中数据进行查询。

2022-08-30
1

Apache Seatunnel - 架构解析

Seatunnel 是一个非常易用,高性能、支持实时流式和离线批处理的海量数据处理产品,架构于Apache Spark 和 Apache Flink之上,开源项目地址:https://github.com/apache/incubator-seatunnel...

2022-08-30
0

Flink - 自己总结了一些学习笔记

创建一个执行环境,表示当前执行程序的上下文。 如果程序是独立调用的,则此方法返回本地执行环境;如果从命令行客户端调用程序以提交到集群,则此方法返回此集群的执行环境,也就是说,getExecutionEnvironment 会根据查询运行...

2022-08-30
0

(6)Flink CEP SQL模拟账号短时间内异地登录风控预警

(1)通过将xxx平台用户登录时的登录日志发送到kafka(本文代码演示用的socket);

2022-08-30
0

Delta Lake 2.0正式发布,Databricks能赢吗?

新粉请关注我的公众号我收到了一封邮件,具体内容截图如下:简单说,就是官宣Delta Lake 2.0正式发布了。这个距离Databricks的年度大会上面宣布,也有些时日了。Databricks在发布里面指出了一些新功能。我挑重点讲几个。首先...

2022-08-29
0

国内用得最多的 Java 框架,它排第一!

对于Java工程师来说,几乎没有没听过大名鼎鼎的Spring框架的,Spring框架早已成为了Java后端开发事实上的行业标准,可以说,是Spring成就了Java,Spring也成为Java程序员必修课之一。同时,随着Spring Boot和Spring Cloud的出现,...

2022-08-29
0