Stella981 Stella981
3年前
Flink 使用(一)——从kafka中读取数据写入到HBASE中
1、前言  本文是在《如何计算实时热门商品》(https://www.oschina.net/action/GoToLink?urlhttp%3A%2F%2Fwuchong.me%2Fblog%2F2018%2F11%2F07%2Fuseflinkcalculatehotitems%2F)\1\一文上做的扩展,
Stella981 Stella981
3年前
Flink+ClickHouse构建亿级电商用户画像平台(PC、移动、小程序)
FlinkClickHouse构建亿级电商用户画像平台(PC、移动、小程序)完整版131节,2020年10月新课本课程采用FlinkClickHouse技术架构实现我们的画像系统,通过学习完本课程可以节省你摸索的时间,节省企业成本,提高企业开发效率。希望本课程对一些企业开发人员和对新技术栈有兴趣的伙伴有所帮助,如对我录制的教程内容有建议请及时
Stella981 Stella981
3年前
Flink FileSink 自定义输出路径——StreamingFileSink、BucketingSink 和 StreamingFileSink简单比较
接上篇:FlinkFileSink自定义输出路径——BucketingSink(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Fwww.cnblogs.com%2FSpringmoonvenn%2Fp%2F11198154.html) 上篇使用BucketingSink实现了
Wesley13 Wesley13
3年前
2019年终总结
序转眼之间2019年就要过去了,又是到了写总结的时候了。盘点去年定了要深入研究流式计算及系统架构,现在看来,流式计算只粗略看了点flink,系统架构方面貌似也没有太多的长进,文章也写的越来越像流水账了,感觉有点惭愧。展望新的一年在新技术方面要研究容器化,在基础方面也得巩固一下linux、network等,最后在架构领域方面
在使用Flink CDC时,源表没有主键如何处理
本文分享自天翼云开发者社区《》,作者:5m在FlinkCDC中,当源表没有主键时,需要设置scan.incremental.snapshot.chunk.keycolumn参数来指定一个或多个列作为切分数据流的关键列。这些列用于在获取增量快照时切割数据流,
streampark+flink一键整库或多表同步mysql到doris实战
streamparkflink一键整库或多表同步mysql到doris实战,此应用一旦推广起来,那么数据实时异构时,不仅可以减少对数据库的查询压力,还可以减少数据同步时的至少50%的成本,还可以减少30%的存储成本;streampark搭建二进制包编译构
扶老携幼 扶老携幼
1年前
Flink 一站式平台 Apache StreamPark 2.1.4 重磅发布
​近日ApacheStreamPark(Incubating)PMC 正式发布了ApacheStreamPark2.1.4版本。在本次发布中,支持了最新的ApacheFlink1.19,简化了项目的配置,FlinkonKubernetes方面的能力做了充分验证,2.1.4版本是目前推荐的稳定版本,建议所有用户升级到这个版本。
轻松入门大数据:玩转Flink,打造湖仓一体架构完结
核心代码,注释必读//download:​​3w52xueitcom​​vue2.x响应式Object.defineProperty基本用法//Object.defineProperty的基本用法constdataconstname'zhangsan'Ob