前言 祝广大女性节日快乐~ 快问快答 Flink DataStream API中的RichFunction有哪些用途/特点？RichFunction中获取到的RuntimeC...
发简信
IP属地：北京
-
Flink RichFunction题目一则 -
无缝更改ClickHouse物化视图SELECT逻辑的方法累成狗的一天，继续超短文模式。 在我司的ClickHouse DWS层有一张ReplicatedAggregatingMergeTree引擎的物化视图，为近线推荐业务提供关键...
-
From Calcite to Tampering with Flink SQL今天为组内同学做了题为「From Calcite to Tampering with Flink SQL」的分享，将Markdown版讲义贴在下面。 本次分享信息量极大，涵盖...
-
打造MacOS版“XShell”1.背景 XShell作为一个强大的安全终端模拟软件，它支持SSH1, SSH2, 以及Microsoft Windows 平台的TELNET 协议。作为server端开发，...
-
spark读取parquet文件优化
业务背景 Spark读取文件时，对于可切分的文件，会将文件切分为一系列 Split ，每个Split对应一个Task。一般而言，Split的大小与HDFS的Block大小相当...
-
HIVE UDTF 自定义函数
HIVE UDTF 自定义函数 关键词：HIVE UDTF 开发 实例Hive运行用户自定义函数对数据信息处理，可以试用show functions查看 hive当前支持的...
-
Flink SQL流式聚合Mini-Batch优化原理浅析前言 流式聚合（streaming aggregation）是我们编写实时业务逻辑时非常常见的场景，当然也比较容易出现各种各样的性能问题。Flink SQL使得用户可以通过简...
-
（跳跃）一致性哈希及其在Greenplum中的应用前言 一致性哈希（consistent hashing）是分布式系统中非常重要的算法，在平滑扩缩容、动态负载均衡等方向有大量应用。相对于传统的线性（取模）哈希算法，一致性哈希...
-
实战自定义Flink SQL Connector（w/ Flink 1.11 & Redis）Foreword Flink SQL之所以简洁易用而功能强大，其中一个重要因素就是其拥有丰富的Connector（连接器）组件。Connector是Flink与外部系统交互的...
