正文

实时即未来！flinkforwardasia2021议程正式上线！

大数据v  大数据v  2023-01-23  435

关键词：

作为开源大数据领域的顶级盛会之一，Flink Forward 持续集结最佳行业实践以及 Flink 最新技术动态，并积极拥抱生态伙伴，共建繁荣开源大数据生态。12 月 4-5 日，北京国家会议中心，Flink Forward Asia 2021 重磅开启，全球 40+ 多行业一线厂商，80+ 干货议题，带来专属于开发者的技术盛宴。大会议程已正式上线，扫描下方二维码即可免费报名~

▼ 扫码预约 ▼

(大会官网)

强大的嘉宾阵容

FFA 2021 邀请了 11 位行业领袖及开拓者组成议题评选委员会，并继续由阿里巴巴开源技术委员会负责人贾扬清担任主席，共同为大会内容护航，他们分别是：

内容重磅升级

Flink Forward Asia 2021 大会内容重磅升级，除了经典的 Flink 核心技术解析、行业最佳实践、实时数仓、开源解决方案、机器学习主题，还新增了平台建设、实时数据湖、流批一体等时下热门方向。

主会场

本届 Flink Forward Asia 将由阿里巴巴开源技术委员会负责人贾扬清进行开场演讲。Apache Flink 中文社区创始人王峰、字节跳动计算基础架构负责人师锐、中国工商银行大数据平台负责人袁一、Pravega 中国社区创始人滕昱将分享基于 Flink 的深度实践以及 Flink 下一步的的规划与展望。

核心技术

由 Apache Flink 核心贡献者与来自阿里巴巴、字节跳动、快手、美团等一线技术专家解析 Flink 技术动向与应用实践。

行业实践

字节跳动、网易、蔚来、中原银行、建信金融、中信建投等多行业实时计算领域专家详细解读 Flink 在业内的应用与落地，围绕业务场景、业务痛点、面临挑战、如何破局等宝贵实践经验倾囊相授。

平台建设

平台建设专场由来自字节跳动、腾讯新闻、网易、京东、滴滴、bilibili、汽车之家、移动、联通、BIGO、蚂蚁金服、翼支付的技术专家分享基于 Apache Flink 的实时计算平台演进与实践。

实时数据湖

来自阿里巴巴、字节跳动、网易的技术专家们将解读如何构建数据湖平台、简化实时数据入湖入仓等相关问题，更有 Flink + Iceberg、Flink + Hudi 构建流式数据湖最佳实践。

实时数仓

实时数仓专场邀请腾讯、快手、美团、科大讯飞、理想汽车、蚂蚁金服、SmartNews、智慧芽、十荟团等多位数仓技术专家分析实时数仓的应用实践及平台智能化的探索与思考。

流批一体

字节跳动、美团、京东、小米的技术专家分享流批一体的生产实践，另有来自阿里巴巴的技术专家手把手教你如何构建流批一体数仓。

开源解决方案

开源大数据生态专场，来自 Pravega、Pulsar、TiDB、Zeppelin 等社区的技术专家围绕 Flink 的生态融合，探讨当下大数据的发展趋势与未来动向，并展现相关技术在一线生产场景的最佳实践。

生产实践

本专场集结阿里巴巴、腾讯、快手、小米、美团的技术专家探讨超大规模Flink集群运维与大规模作业稳定性优化实践等议题。

机器学习

人工智能专场由来自阿里巴巴、京东、360 等技术专家呈现 Flink 机器学习的最新进展、具体应用实践与最新技术落地案例。

Tips：

Flink Forward Asia 2021 大会最终议程以官网公布信息为准。
官网链接 https://flink-forward.org.cn/，点击议题，即可查看议题详情以及讲师介绍。

点击下方「阅读原文」即可报名大会，了解更多 Flink Forward Asia 2021 大会信息。时代的进程浩浩荡荡，2021 我们一起，把握大数据的潮向，向未来致敬！

Flink Forward Asia 2021 赞助与合作

更多 Flink 相关技术问题，可扫码加入社区钉钉交流群～

▼ 关注「Flink 中文社区」，获取更多技术干货 ▼

戳我，报名 FFA 2021 大会！

从flinkforwardasia2021，看flink未来开启新篇章

...ff0c;而Flink在2021年也开启了新的篇章。2022年1月8-9号，FlinkForwardAsia（FFA）线上峰会成功举行。FlinkForwardAsia是由Apache官方授权，ApacheFlink中文社区主持举办的会议。查看详情

实时即未来，车联网项目之远程诊断实时故障分析(代码片段)

文章目录远程诊断实时故障业务什么是远程诊断实时故障应用场景介绍常用故障分析指标与含义业务中间表数据结构分析结果表数据结构高德地图解决逆地理坐标问题实时故障分析任务远程诊断实时故障分析车型车系销售信息广... 查看详情

实时即未来，车联网项目之远程诊断实时故障分析(代码片段)

实时即未来，大数据项目车联网之实时etl任务消费数据

文章目录1实时ETL任务消费数据1消费数据解析逻辑2测试实时ETL消费数据1封装flink流处理环境初始化工具类1创建基础任务处理基类2测试实时ETL消费数据1实时ETL任务消费数据1消费数据解析逻辑创建流式环境，设置检查点、kafka分区... 查看详情

实时即未来，车联网项目之原始终端数据实时etl(代码片段)

文章目录Flink将报文解析后的数据推送到kafka中实时ETL开发原始数据的实时ETL设置开发的流程开发的类名——KafkaSourceDataTask设置checkpoint中statebackend数据积压和反压机制抽象BaseTask用于处理数据流和读取kafka数据Flink将报文解析后的... 查看详情

实时即未来，车联网项目之原始终端数据实时etl(代码片段)

实时即未来，大数据项目车联网之原始数据实时etl任务消费数据策略

文章目录实时ETL业务开发1原始数据实时ETL分析2实时ETL开发流程分析3解析工具类引入1日期处理工具2配置文件加载工具3字符串处理工具4JSON解析工具4原始数据实时ETL任务设置1checkpoint配置实时ETL业务开发1原始数据实时ETL分析根据... 查看详情

实时即未来，大数据项目车联网之驾驶行程采样实时分析十七

文章目录1.驾驶行程采样实时分析2.驾驶行程指标分析2.1里程、SOC、行程消耗时间分析2.2高速、中速、低速soc消耗分析2.3高速、中速、低速里程分析2.4高速、中速、低速车次分析2.5驾驶行程剩余指标业务3.总结1.驾驶行程采样实时... 查看详情

实时即未来，大数据项目车联网之原始数据实时etl任务消费数据策略

实时即未来，大数据项目车联网之原始数据实时etl落地hbase

文章目录1.原始数据实时ETL落地HBase1rowkey设计原则和方法1RowKey的设计原则1rowkey长度原则2rowkey散列原则3rowkey唯一原则2常用的rowkey设计方法2.1Salt加盐2.2Hash散列或者Mod2.3Reverse反转2实时ETL数据落地hbase步骤分析第一种继承RichSinkFuncti... 查看详情

实时即未来，大数据项目车联网之创建flink实时计算子工程(代码片段)

文章目录写在前面车联网项目全新升级创建Flink实时计算子工程1在原工程下创建实时分析子模块2导入实时分析子模块pom依赖3配置实时分析子模块资源文件写在前面车联网项目全新升级更全8-》21+篇更细-》图文并茂、部分代码... 查看详情

实时即未来，大数据项目车联网之驾驶行程采样实时分析十七

实时即未来，大数据项目车联网之实时etl开发的核心逻辑(代码片段)

文章目录1实时ETL开发的核心逻辑1自定义方法解析json数据2实时ETL数据存储2.1数据落地HDFS：*StreamingFileSink*2.1文件格式2.2桶分配逻辑2.3滚动策略2.2异常数据落地*hdfs*3正常数据落地*hdfs*1实时ETL开发的核心逻辑1自定义方法解析json数... 查看详情

实时即未来，大数据项目车联网之实时etl开发的核心逻辑(代码片段)

实时即未来，大数据项目车联网之flinkwatermark(水位线)十四

文章目录1FlinkWatermark(水位线)1事件时间（eventtime）2FlinkWindowAssigners（窗口分配器）2.1TumblingWindows（翻滚窗口）2.2SlidingWindows（滑动窗口）2.3SessionWindows（会话窗口）2.4GlobalWindows（全局窗口）2.5窗口函数（WindowFunction）1FlinkWatermark(... 查看详情