flink sql 知其所以然（二）| 自定义 redis 数据维表（附源码）
维表实现篇-维表实现的过程 总结与展望篇 本文主要介绍了 flink sql redi ...
原文：flink sql 知其所以然（五）| 自定义 protobuf format
感谢您的关注 点赞 再看，对博主的肯定，会督促博主持续的输出更多的优质实战内容 .序篇 本文结构 大数据羊说 用数据提升美好事物发生的概率 篇原创内容 公众号 protobuf作为目前各大公司中最广泛使用的高效的协议数据交换格式工具库，会大量作为流式数据传输的序列化方式，所以在 flink sql 中如果能实现protobuf的format会非常有用 目前社区已经有对应的实现，不过目前还没有 m ...
2021-08-25 21:21 0 100 推荐指数：
相关推荐
知其所以然~字典的数据结构
Dictionary和hashtable用法有点相似，他们都是基于键值对的数据集合，但实际上他们内部的实现原理有很大的差异， 先简要概述一下他们主要的区别，稍后在分析Dictionary内部实现的大 ...
./configure & make & make install 知其所以然
最近一直在类unix系统上（Ubuntu和Mac OS）上调研第三方的一些开源库，要涉及到开源库的编译安装工作，接触最多的就是./configure & make & make ins ...
知其所以然~redis的原子性
原子性 原子性是数据库的事务中的特性。在数据库事务的情景下，原子性指的是：一个事务（transaction）中的所有操作，要么全部完成，要么全部不完成，不会结束在中间某个环节。 对于Redis而言， ...
Flink 源码 | 自定义 Format 消费 Maxwell CDC 数据
Flink 1.11 最重要的 Feature —— Hive Streaming 之前已经和大家分享过了，今天就和大家来聊一聊另一个特别重要的功能 —— CDC。 CDC概述 何为CDC？Change Data Capture，将数据库中的’增’、’改’、’删’操作记录下来。在很早之前 ...
Flink 1.10 SQL 自定义KafkaUpsertSink
在 Flink 1.10 中SQL正式生产，在尝试使用的时候，遇到了这样的问题： KafkaTableSink 的 'update-mode' 只支持 ‘append’，如下面这样： 看起来好像没问题，因为kafka 也只能往里面写数据，不能删数据 官网链接：https ...
Flink sql kafka source 自定义并行度
本文参考康琪大佬的博客：使Flink SQL Kafka Source支持独立设置并行度 一直觉得 Flink Sql 需要指定算子并行度的功能，哪怕是基于 SQL 解析出来的算子不能添加并行度，source、sink、join 的算子也应该有修改并行度的功能。 恰好看到大佬的博客 ...
在自定义Flink1.10 Sql Sink遇到的问题
1.org.apache.flink.table.api.TableException: Table sink does not implement a table schema. 问题：在RedisTableSink中没有重写getTableSchema方法 解决：增加 ...