1、Flink在58同城应用与实践 58同城 冯海涛 实时计算平台架构 实时SQL建设 Storm 迁移 Flink实践 一站式实时计算平台 后续规划 目录 实时计算平台架构01 平台定位 为58集团海量数据提供高效、稳定实时计算 一站式服务 实时数据存储 实时数据计算 实时数据分发 Kafka Storm/Spark Streaming Flink 基础能力建设 DDS数据分发(Kafka Connect) Wstream一站式实时计算平台 平台化建设 定位平台 实时架构 实时业务场景和诉求 业务诉求: 1.高吞吐/低延迟的计算能力; 2.灵活窗口支持; 3.数据乱序; 4.Exactly on
2、ce语义保障; 5.中间状态管理 场景: 业务: 实时ETL 实时数仓 实时监控 实时数据流分析 Flink集群 高可用架构 任务隔离 业务 业务 招聘 商业 金融 . 计算型 IO型 场景 集群规模 900+ 机器数 2000+ 实时任务 数 2.5万亿 日实时计 算数据 3000万 每秒峰值 Flink On YARN HDFS Fedration Cgrou p Node Label 实时SQL建设02 实时SQL演进 Flink上线DDL扩展支持实时SQL平台化合并Blink社区最新版数仓化 DMLDDL定义 维表join 实时存储扩展 配置化 可视化开发 在线调试 . Mini Ba
3、tch Emit 数据倾斜 TopN . 批流合一 Flink Hive 元数据管理 血缘关系 数仓分层 存储扩展 实现功能 支持DDL语法 维表join 打通主流存储和公司内部实时存储 定制format支持 支持并发度设置 wmb kafka 源表 mysqlhbaseredis wrediswtable kafka mysql hbase wtable ck redis Stream sql 性能优化 MiniBatch Local-Global聚合 Emit功能 异步IO机制 异步client 多线程 缓存LRU 缓存条数 过期时间 单并发度多线程写入 Sink算子buffer Consumer 1 Stream Consumer 2 Consumer N sink Blink特性 数仓化建设 目标: 提供面向数仓化实时Sql能力,在数仓设计,任务开发, 平台化管理全面对齐离线数仓的
1、下载报告失败解决办法 2、PDF文件下载后,可能会被浏览器默认打开,此种情况可以点击浏览器菜单,保存网页到桌面,就可以正常下载了。 3、本站不支持迅雷下载,请使用电脑自带的IE浏览器,或者360浏览器、谷歌浏览器下载即可。 4、本站报告下载后的文档和图纸-无水印,预览文档经过压缩,下载后原文更清晰。
电信网络中的图学习性能优化-曾立.pdf
GraphGPT_汤嘉斌_hku.pdf
朱雀图计算平台与大模型-0908.pdf
240127腾讯游戏大规模图学习研究与落地 .pdf
图机器学习在京东内容推荐中的应用-京东-姚翔宇.pdf
图在金融反欺诈中的应用.pdf
张梦玫datafun分享_final_zmm.pdf
大语言模型对汽车行业的影响和实践探索_分享版.pdf
三七互娱AI客服分享-datafun.pdf
任旭滨LLMs Enhanced Rec.pdf
动态推荐场景下的图学习.pdf
旅行经营决策中的时序预测应用.pdf
用户画像的分类及应用介绍.pdf
AnalyticDB PostgreSQL实时物化视图在飔合科技实时数仓的实践.pdf
【微软】A Unified Database for Scalar-Vector Data.pdf
NIO-段全盛-应用大模型打造企业级信息引擎.pdf
三个皮匠报告专业的行业报告下载站,每日更新,欢迎大家关注!
copyright@2008-2013 长沙景略智创信息技术有限公司版权所有 网站备案/许可证号:湘B2-20190120
专属顾问
机构入驻、侵权投诉、商务合作
三个皮匠报告官方公众号
验证即登录,未注册将自动创建三个皮匠报告账号
使用 微信 扫一扫登陆