首页
博客
源码
资源
博客
源码
写文章
发布博客
发布资源
登录
X
flink
相关资讯
热门
最新
后端
01-01 08:00
后端
Flink State、CheckPoint与Savepoint、Flink的Exactly Once
State State简述 State分类: Keyed state Operator state State两种形态: Raw State(原始状态)只需要继承RichFunction系列而不需要...
137
后端
01-01 08:00
后端
FlinkSQL写入Kafka/ES/MySQL示例-JAVA
FlinkSQL写入Kafka/ES/MySQL示例-JAVA,FlinkSQL写入Kafka/ES/MySQL示例-JAVA一、背景说明Flink的API做了4层的封装,上两层TableAPI、SQL语法相对简单便于编写,面对小需求可以快速上手解决,本文参考官网及部分线上教程编写source端、sink端代码,分别读取socket、kafka及文本作为source,并将流数据输出写入Kafka、
135
后端
01-01 08:00
后端
Flink如何管理Kafka 消费位点(译文)
Checkpointing 是 Flink 故障恢复的内部机制。一个 checkpoint 就是 Flink应用程序产生的状态的一个副本。如果 Flink 任务发生故障,它会从 checkpoint...
133
后端
01-01 08:00
后端
Flink TaskManager 内存模型详解
Apache Flink 通过严格控制其各个组件的内存使用,在 JVM 之上提供了高效的工作负载。虽然社区努力为所有配置提供合理的默认值,但不可能适用于用户在 Flink 上部署的所有应用程序。为了...
132
代码人生
01-01 08:00
代码人生
Flink常用的DataSet 和 DataStream API
Flink常用的DataSet 和 DataStream API 一、说好的流批一体呢? 1、现状 Flink并没有安全支持所谓的“流批一体”,即编写一套代码,可以同时支持流式计算和批量计算的场景。目前版本1.10依然采用DataSet和DataStream两套API来适配不同的应用场景。 2、DataSet和DataStream的区别和联系 &n
132
后端
01-01 08:00
后端
Flink如何管理Kafka 消费位点(译文)
Checkpointing 是 Flink 故障恢复的内部机制。一个 checkpoint 就是 Flink应用程序产生的状态的一个副本。如果 Flink 任务发生故障,它会从 checkpoint...
126
代码人生
01-01 08:00
代码人生
Flink Cumulate Window
Flink Cumulate Window Flink 累计窗口 接上篇: [如何用flink sql写,3h,7h,1d内pv,uv] (https://www.cnblogs.com/Springmoon-venn/p/15179311.html) 之前一直比较遗憾,Flink Sql 没有 Trigger 功能,长时间的窗口不能在中途触发计算,输出中间结果。而很多实时指标是小时、天级的累集
123
后端
01-01 08:00
后端
FlinkSQL元数据验证
Flink1.9以后引入CatalogManager来管理Catalog和CatalogBaseTable,在执行DDL语句时将表信息封装为CatalogBaseTable存储在CatalogMan...
122
后端
01-01 08:00
后端
Flink读取Kafka数据写入Hive
前言 本文针对数据库CDC(change data capture)场景设计,探讨基于Flink1.12最新版本提供的实时写入Hive的技术可行性,下面为本地IDEA程序案例可供参考。 一、整体思路...
121
后端
01-01 08:00
后端
Flink 一 环境搭建,输出wordCount
Flink 一 环境搭建,输出wordCount,1.Flink环境搭建1.1Flink版本列表:archive.apache.org/dist/flink/1.2选择最新的1.12.2版本进行安装wgethttps://archive.apache.org/dist/flink/flink-1.12.2/flink-1.12.2-bin-scala_2.12.tgz复制代码1.3解压安装tar-
120
«
1
2
3
4
5
6
7
8
...
14
15
»