前言 祝广大女性节日快乐~ 快问快答 Flink DataStream API中的RichFunction有哪些用途/特点?RichFunction中获取到的RuntimeC...
前言 祝广大女性节日快乐~ 快问快答 Flink DataStream API中的RichFunction有哪些用途/特点?RichFunction中获取到的RuntimeC...
图片加载不出来😄
Flink RocksDB托管内存机制的幕后——Cache & Write Buffer Manager前言 为了解决Flink作业使用RocksDB状态后端时的内存超用问题,Flink早在1.10版本就实现了RocksDB的托管内存(managed memory)机制。用户只...
我来了大哥😎
Flink 1.10 SQL、HiveCatalog与事件时间整合示例本文已授权「Flink中文社区」微信公众号发布并标注原创。 前言 Flink 1.10与1.9相比又是个船新版本,在我们感兴趣的很多方面都有改进,特别是Flink SQL。本...
看来已经在为东哥卖命了😎😎
浅谈Flink对象重用(object reuse)前言 今天是大年初一,祝各位虎年大吉大利~ 近期受工作变动影响,博客又荒废了许久。今天难得有空,就前段时间内部技术分享里提到的一个小知识点来写几笔。 对象重用(object ...
@LittleMagic 那岂不是带团队了 手下还缺人么 带我啊
2021。2021年的最后几个小时了,抽空来写几笔。待会儿再揭晓年度最佳单曲。 健康 新冠疫情仍然没有趋缓的迹象。看着近期又开始上涨的确诊病例数,还有承载着不同生活轨迹的流调报告,有时...
@LittleMagic 是不是技术顾问,已经入职了吗 有没有一个名字叫lihe的同事
2021。2021年的最后几个小时了,抽空来写几笔。待会儿再揭晓年度最佳单曲。 健康 新冠疫情仍然没有趋缓的迹象。看着近期又开始上涨的确诊病例数,还有承载着不同生活轨迹的流调报告,有时...
大哥来头条了吗😍
2021。2021年的最后几个小时了,抽空来写几笔。待会儿再揭晓年度最佳单曲。 健康 新冠疫情仍然没有趋缓的迹象。看着近期又开始上涨的确诊病例数,还有承载着不同生活轨迹的流调报告,有时...
@LittleMagic 老大 还等着你那招人呢 什么时候有信😂
From Calcite to Tampering with Flink SQL今天为组内同学做了题为「From Calcite to Tampering with Flink SQL」的分享,将Markdown版讲义贴在下面。 本次分享信息量极大,涵盖...
@LittleMagic 😄等你好消息
From Calcite to Tampering with Flink SQL今天为组内同学做了题为「From Calcite to Tampering with Flink SQL」的分享,将Markdown版讲义贴在下面。 本次分享信息量极大,涵盖...
累成狗的一天,继续超短文模式。 在我司的ClickHouse DWS层有一张ReplicatedAggregatingMergeTree引擎的物化视图,为近线推荐业务提供关键...
今天为组内同学做了题为「From Calcite to Tampering with Flink SQL」的分享,将Markdown版讲义贴在下面。 本次分享信息量极大,涵盖...
spark的codegen源码大佬能给讲讲么
From Calcite to Tampering with Flink SQL今天为组内同学做了题为「From Calcite to Tampering with Flink SQL」的分享,将Markdown版讲义贴在下面。 本次分享信息量极大,涵盖...
大哥你们是不是要被合并到阿里了😄
「I believe what you said」时隔三个月之后的第一首歌词,当然要搞搞事情了( 2020年10月动画《寒蝉泣之时 业》(ひぐらしのく頃に 業)片头曲 https://y.qq.com/n/ryqq/song...
1.背景 XShell作为一个强大的安全终端模拟软件,它支持SSH1, SSH2, 以及Microsoft Windows 平台的TELNET 协议。作为server端开发,...
HIVE UDTF 自定义函数 关键词:HIVE UDTF 开发 实例Hive运行用户自定义函数对数据信息处理,可以试用show functions查看 hive当前支持的...
说点什么吧
「ピンクレモネード」(粉色柠檬水)三月都快要过去了,怎么能不来一首「三月的幻想」的歌呢hhh 2018年10月动画《只要贝尔哲布布大小姐喜欢就好。》片头曲https://y.qq.com/n/yqq/song...
前言 流式聚合(streaming aggregation)是我们编写实时业务逻辑时非常常见的场景,当然也比较容易出现各种各样的性能问题。Flink SQL使得用户可以通过简...
前言 一致性哈希(consistent hashing)是分布式系统中非常重要的算法,在平滑扩缩容、动态负载均衡等方向有大量应用。相对于传统的线性(取模)哈希算法,一致性哈希...
来了来了😎
实战自定义Flink SQL Connector(w/ Flink 1.11 & Redis)Foreword Flink SQL之所以简洁易用而功能强大,其中一个重要因素就是其拥有丰富的Connector(连接器)组件。Connector是Flink与外部系统交互的...