一、写入mysql 1.pom.xml 2.在flink中没有现成的用来写入MySQL的sink，但是flink提供了一个类，JDBCOutputFormat，通过这个类，如果你提供了jdbc的driver，则可以当做sink使用。 JDBCOutputFormat其实是 ...

Flink 读写Kafka 在Flink中，我们分别用Source Connectors代表连接数据源的连接器，用Sink Connector代表连接数据输出的连接器。下面我们介绍一下Flink中用于读写kafka的source & sink connector。 Apache ...

iceberg 0.11 发布的时候稍微尝试了一下，发现实际并没有说的那么厉害，很多功能其实还在开发中(比如： upsert) 贴段之前写的 flink sql： 注： 貌似没有 hive catalog，只能放在 hadoop 上面，不支持 upsert iceberg master ...

项目pom文件 实现flink写入redis 实现wordcount功能，并将结果实时写入redis，这里使用了第三方依赖flink-connector-redis_2.11，该依赖提供了RedisSink可以直接使用，具体代码如下： 代码 首先定义数据源处理实现类 ...

最近因为疫情的原因，偷了好长时间的懒，现在终于开始继续看Flink 的SQL 了 ———————————————— 电脑上的Flink 项目早就升级到了 1.10了，最近还在看官网新的文档，趁着周末，体验一下新版本的SQL API（踩一下坑）。 直接从之前的 云邪大佬的Flink ...

...

Flink的kafka connector文档 https://ci.apache.org/projects/flink/flink-docs-release-1.12/zh/dev/connectors/kafka.html Flink写入kafka时候需要实现序列化和反序列化 ...

源码结构 RedisSink RedisSink类继承了RichSinkFunction类，扩展了其中的open、invoke、close方法。open方法在sink打开时执行一次，在Re ...