课程 FlinkX基础教程

FlinkX基础教程

 1753 1  14.0课时  15923人学习
本课程主要为FlinkX基础课程,为大家介绍FlinkX相关内容
  • 第1节:第一节丨初识FlinkX

    开始学习
  • 第2节:第二节丨FlinkX使用入门及贡献

    开始学习
  • 第3节:第三节丨FlinkX实时采集原理与使用

    开始学习
  • 第4节:第四节丨FlinkX增量同步和断点续传功能

    开始学习
  • 第5节:第五节丨FlinkX-RDB模块使用场景与演示

    开始学习
  • 第6节:第六节丨FlinkX-Oracle Logminer模块介绍

    开始学习
  • 第7节:第七节丨FlinkX SqlServer CDC实时采集原理与使用

    开始学习
  • 第8节:第八节丨Flink jm、tm启动过程和资源分配

    开始学习
  • 第9节:第九节丨如何自定义Flink LookupTable

    开始学习
  • 第10节:第十节丨Flink Checkpoint&Barrier 简介及源码详解

    开始学习
  • 第11节:第十一节丨Flink SQL转换Operator流程及源码解析

    开始学习
  • 第12节:第十二节丨Flink Metric 的原理与扩展

    开始学习
  • 第13节:第十三节丨Flink Exactly Once & Kafka-connector 算子

    开始学习
  • 第14节:第十四讲丨FlinkX HDFS Write vs StreamFileSink设计原理与使用

    开始学习

课程介绍

FlinkX是一个基于Flink的批流统一的数据同步工具,既可以采集静态的数据,比如MySQL,HDFS等,也可以采集实时变化的数据,比如MySQL binlog,Kafka等。同时,FlinkX也是支持原生FlinkSql所有语法和特性的计算框架,并且提供了大量案例。FlinkX目前包含下面这些特性:1)大部分插件支持并发读写数据,可以大幅度提高读写速度;2)部分插件支持失败恢复的功能,可以从失败的位置恢复任务,节约运行时间;3)关系数据库的Source插件支持间隔轮询功能,可以持续不断的采集变化的数据;4)部分数据库支持开启Kerberos安全认证;5)可以限制source的读取速度,降低对业务数据库的影响;6)可以记录sink插件写数据时产生的脏数据;7)可以限制脏数据的最大数量;8)支持多种运行模式;9)同步任务支持执行flinksql语法的transformer操作;10)sql任务支持和flinkSql自带connectors共用

讲师简介

第一节讲师:江博丨袋鼠云数栈高级大数据运维工程师

社区公告
  • 大数据领域最专业的产品&技术交流社区,专注于探讨与分享大数据领域有趣又火热的信息,专业又专注的数据人园地

最新活动更多
微信扫码获取数字化转型资料
钉钉扫码加入技术交流群