包含标签：flink 的文章
-
我眼中的大数据（一）
前言 在正式落地谈技术之前，先花一些篇幅说说大数据技术的发展史。我们常说的大数据技术，其实起源于Google在2004年前后发表的三篇论文，分别是分布式文件系……admin 2022-09-23
-
网易游戏 Flink SQL 平台化实践
摘要：本文整理自网易游戏资深开发工程师林小铂在 Flink Forward Asia 2021 平台建设专场的演讲。主要内容包括： 网易游戏 Flink SQL 发展历程 基于模板 ja…… -
【flink on yarn】/root/.flink/application_xxxxx/force-shading-1.9.1.jar does not exist
1.背景 启动脚本大致内容如下： 直接sh 执行这个脚本能正常拉起 但crontab -e配置这个脚本定时执行后报下面的错误： 2.原因分析 crontab 执行时没有加载到/…… -
Flink(scala)整合MySQL统计UV(unique visitor)
数据源是尚硅谷的课件, 需要的话可以私信我 核心代码 import org.apache.flink.api.common.serialization.SimpleStringSchema import org.apache.flink.confi…… -
实时数仓与离线数仓架构对比、Flink消费流程
实时数仓架构图： 离线数仓： 与离线数仓区别： MySQL业务数据采集改用FlinkCDC;FlinkCDC与Maxwell处理方式和Cannal一样通过监控binlog方式（行级别），…… -
Flink使用KafkaSource从Kafka消息队列中读取数据
Flink使用KafkaSource从Kafka消息队列中读取数据 使用KafkaSource从Kafka消息队列中读取数据 1.KafkaSource创建的DataStream是一个并行的DataStream 2.KafkaS…… -
Flink 用户电商行为分析项目
Flink 用户电商行为分析 文章目录 Flink 用户电商行为分析 1. 实时统计分析 1. 1 热门商品统计 1. 2 热门页面统计 1. 3 网站uv统计 2. 业务流…… -
Flink使用local模式执行Flink程序，并且开启Flink的webUI
Flink使用local模式执行Flink程序，并且开启Flink的webUI 使用local模式执行Flink程序，并且开启Flink的webUI 1.在pom.xml中引入依赖 org.apache.flink flin…… -
doris 15 详细docker 编译 以及drois-flink的编译
1. 编译对应的版本 https://doris.apache.org/master/zh-CN/installing/compilation.html 这里选择 docker15 编译 2.docker 拉去镜像 [[email protected] ~]# d…… -
Flink自定义Sink将数据存到MySQL
如有更佳的保存MySQL方法 欢迎私信或留言分享 相互学习~ import org.apache.flink.streaming.api.functions.sink.RichSinkFunction // 自定义Sink dataStre……