精华内容
下载资源
问答
  • flink大数据相关介绍ptf文档,flink大数据相关介绍ptf文档,flink大数据相关介绍ptf文档,flink大数据相关介绍ptf文档,flink大数据相关介绍ptf文档,flink大数据相关介绍ptf文档,
  • 【就业课】Hadoop/Spark/Flink大数据开发工程师
  • Flink大数据实时计算系列-Flink的savepoint 目录 Flink的savepointname案例实战Flink参考链接Flink系列博客 Flink的savepoint jobid yarn模式 name案例实战 package com.flinkniu.flink.operator; ...

    Flink大数据实时计算系列-Flink的savepoint

    Flink的savepoint

    在这里插入图片描述

    在这里插入图片描述

    展开全文
  • Flink大数据实时计算系列-Flink程序恢复机制 目录Flink程序恢复机制Flink程序恢复机制案例实战FileSourceRestart设置Flink程序恢复代码Flink参考链接Flink系列博客 Flink程序恢复机制 Flink程序恢复机制案例实战 ...
    展开全文
  • Flink大数据项目实战 10年一线开发及项目管理经验,6年以上大数据项目架...

    扫码下载「CSDN程序员学院APP」,1000+技术好课免费看

    APP订阅课程,领取优惠,最少立减5元 ↓↓↓

    订阅后:请点击此处观看视频课程

     

    视频教程-Flink大数据项目实战-大数据

    学习有效期:永久观看

    学习时长:2681分钟

    学习计划:45天

    难度:

     

    口碑讲师带队学习,让你的问题不过夜」

    讲师姓名:杨俊

    架构师

    讲师介绍:10年一线开发及项目管理经验,6年以上大数据项目架构、实施、开发与运维经验,骨灰级大数据玩家,对Hadoop、Storm、Spark、Flink、Kylin、Druid等大数据技术有较深研究。搭建、维护过上百节点集群,处理过PB级数据。 因技术出色,多次在知名企业内部进行大数据技能培训,对一线企业大数据方面的技能需求非常了解。 热爱分享,喜欢结合切身经历的大型项目经验来授课,用血淋淋的一线案例、真刀真枪的现场演示、实时的回馈指导赢得了很多学员的仰慕和好评。

    ☛点击立即跟老师学习☚

     

    「你将学到什么?」

    本课程基于某电商公司运营实时分析系统(2B),进行全方位、无死角系统讲解。通过本课程的学习,既能获得Flink企业级真实项目经验,也能深入掌握Flink的核心理论知识,还能获得Flink在生产环境中安装、部署、监控的宝贵经验,从而一站式全面、深入掌握Flink技术。

     

    「课程学习目录」

    第1章:Flink概述
    1.初识flink
    2.flink生态
    3.Flink use cases
    4.Flink当前发展现状及未来趋势
    第2章:Flink初探
    1.flink批处理案例实现
    2.Flink流处理案例实现
    第3章:Flink核心概念与编程模型
    1.分层架构
    2.DataFlow
    3.window、time、state及checkpoint
    第4章:Flink Runtime(一)
    1.Flink slot分配与共享
    2.Flink slot与parallelism的关系
    第5章:05Flink Runtime(二)
    1.Flink部署方式
    2.Flink Standalone 安装部署
    3.Flink服务启动与测试
    第6章:Flink开发环境搭建
    1.Flink依赖管理
    2.Flink源码编译
    3.Flink源码编译错误大盘点
    第7章:Flink API通用基本概念
    1.flink编程基本套路
    2.flink自定义转换函数
    3.flink累加器和计数器
    第8章:DataStream API入门(1)
    1.Datastream编程基本套路
    2.flink数据源
    3.flink execution参数
    第9章:perators串烧
    1.DataStream Transformation盘点(1)
    2.DataStream Transformation盘点(2)
    3.物理分区
    4.任务链和资源组相关操作
    第10章:Time的故事
    1.Time三兄弟
    2.时间戳和水位线背后的机制
    3.生成Timestamp和Watermark及预定义处理
    第11章:window的那些事
    1.window是啥
    2.窗口分配器
    3.窗口函数
    4.触发器和驱逐器
    5.延迟处理及窗口计算结果的使用
    第12章:Operators之CoGroup及Join操作
    1.CoGroup与Join
    第13章:Process Function
    1.Process Function
    2.Timers
    第14章:异步IO Operator
    1.Aysnc I/O API
    2.Aysnc I/O原理
    第15章:Connector大盘点及自定义source与sink
    1.Connector大盘点及自定义source与sink
    第16章:Connectors之kafka
    1.FlinkKafkaSource序列化、消费模式
    2.FlinkKafkaSource容错、动态分区及topic
    3.FlinkKafkaSink序列化、配置、分区与容错
    第17章:状态与容错
    1.理解state状态
    2.Operator State 的使用及Redistribute
    3.Keyed State的使用与Redistribute
    4.Broadcast State的妙用
    5.Checkpoint使用条件及使用步骤
    6.Checkpoint相关配置及重启策略
    7.Checkpoint核心原理剖析
    8.Savepoint的触发、Job恢复及删除
    第18章:Flink单测与集成测试
    1.Flink单测与集成测试
    第19章:Flink流处理电商项目
    1.用户购买行为跟踪:需求、分析、方案
    2.电商项目业务开发1:参数校验、checkpoint设置、statebackend设置、restart
    3.电商项目业务开发2:全局配置、实体类、Kafka数据消费、事件流、配置流、流连接、反序列化器、Kaf
    4.电商项目业务开发3:用户购买行为相关核心业务实现
    5.电商项目业务开发4:电商数据接入及项目联调
    第20章:DataSet API概述
    1.DataSet编程基本套路、数据源、转换
    2.DataSet对象重用、语意注解、广播变量、分布式缓存、函数传参
    第21章:DataSet Transformation串烧
    1.DataSet 常规Transformation
    2.DataSet join相关Transform
    第22章:迭代运算
    1.迭代运算(1)
    2.迭代运算(2)
    第23章:DataSetUtils工具类
    1.DataSetUtils工具类
    第24章:批处理容错
    1.批处理容错
    第25章:批处理Connectors
    1.批处理Connectors(1)
    2.批处理Connectors(2)
    第26章:Flink批处理电商项目
    1.项目需求分析与架构设计
    2.数据实时增量同步与全量拉取
    3.项目相关环境准备
    4.数据入库Hbase
    5.全量拉取模块代码实现
    6.增量实时同步模块(1)
    7.增量实时同步模块(2)
    8.配置管理模块
    9.计算与可视化(1)
    10.计算与可视化(2)
    第27章:Flink序列化
    1.Flink序列化
    第28章:Execution管理
    1.Execution管理(上)
    2.Execution管理(下)
    第29章:Flink最佳实践
    1.Flink最佳实践
    第30章:生产环境与部署补充知识
    1.生产环境与部署补充知识(上)
    2.生产环境与部署补充知识(下)
    第31章:Flink Metrics与监控
    1.Flink Metrics与监控
    第32章:【新增】Flink1.9新特性(2020最新)
    1.Flink1.9 on YARN(基于HDP3.1)部署、运行、测试
    2.Flink1.9重大改进和新功能
    3.Wormhole中台方式使用Flink1.9引擎
    第33章:【新增】Flink SQL(2020最新)
    1.Flink Table API和SQL介绍
    2.Flink SQL编程套路-Stream SQL
    3.Flink SQL编程套路-Batch SQL
    4.Flink SQL编程套路-Batch Table
    5.Flink API&SQL流处理介绍
    6.动态表与连续查询
    7.表转流-Append-only 模式
    8.表转流-Retract 模式
    9.Flink SQL读取Kafka代码实现
    10.Flink SQL读取Kafka测试运行
    11.Flink Table API实操
    12.Flink SQL实操

     

    7项超值权益,保障学习质量」

    • 大咖讲解

    技术专家系统讲解传授编程思路与实战。

    • 答疑服务

    专属社群随时沟通与讲师答疑,扫清学习障碍,自学编程不再难。

    • 课程资料+课件

    超实用资料,覆盖核心知识,关键编程技能,方便练习巩固。(部分讲师考虑到版权问题,暂未上传附件,敬请谅解)

    • 常用开发实战

    企业常见开发实战案例,带你掌握Python在工作中的不同运用场景。

    • 大牛技术大会视频

    2019Python开发者大会视频免费观看,送你一个近距离感受互联网大佬的机会。

    • APP+PC随时随地学习

    满足不同场景,开发编程语言系统学习需求,不受空间、地域限制。

     

    「什么样的技术人适合学习?」

    • 想进入互联网技术行业,但是面对多门编程语言不知如何选择,0基础的你
    • 掌握开发、编程技术单一、冷门,迫切希望能够转型的你
    • 想进入大厂,但是编程经验不够丰富,没有竞争力,程序员找工作难。

     

    「悉心打造精品好课,45天学到大牛3年项目经验」

    【完善的技术体系】

    技术成长循序渐进,帮助用户轻松掌握

    掌握大数据知识,扎实编码能力

    【清晰的课程脉络】

    浓缩大牛多年经验,全方位构建出系统化的技术知识脉络,同时注重实战操作。

    【仿佛在大厂实习般的课程设计】

    课程内容全面提升技术能力,系统学习大厂技术方法论,可复用在日后工作中。

     

    「你可以收获什么?」

    3分理论、7分实战

    紧贴项目,发散性、扯淡的地方往往比较重要

    弱化ppt,强调实战操作+笔记整理

    注重课程的趣味性,与实际项目相结合

     

    展开全文
  • Flink大数据实时计算系列-Flink解决数据倾斜 目录 Flink 算子间数据传递Flink 解决one-to-one数据倾斜rebalancerescaleFlink 解决Redistributing streams (keyby)数据倾斜DataStream的partitionCustom方法自定义分区...
  • Flink大数据实时计算系列-Flink算子的transformations关系 目录 Transformations关系图Flink代码案例KeyedStream、DataStream、AllWindowedStream的相互转换KeyedStream的window、connectFlink系列博客 ...
  • Flink大数据实时计算系列- Flink的聚合函数练习 目录 Flink Transformations关系Flink聚合函数案例实战文件数据源FileCountryDictSourceFuntionkakfa数据源...
  • Flink大数据实时计算系列-Flink内置的Sink 目录 Flink内置的Sink基于文件输出Socket输出print输出基于文件输出writeAsText案例实战基于Socket输出案例实战Flink参考链接Flink系列博客 Flink内置的Sink 基于文件...
  • Flink大数据实时计算系列-Flink自定义sinkfunction 目录 Flink自定义sinkfunctionFlink参考链接Flink系列博客 Flink自定义sinkfunction @Public public abstract class RichSinkFunction<IN> extends ...
  • Flink大数据实时计算系列-Flink的slot共享 Flink Slot flatMap并行度为2,filter不设置并行度。 package com.flinkniu.flink.operator; import org.apache.flink.api.common.functions.FilterFunction; import org....
  • Flink China 社区线下 Meetup·北京站 PPT 资料分享 【05 大沙】Flink大数据计算的机遇与挑战
  • Flink大数据实时计算系列-Flink的connect算子用法 目录 Flink的connect算子案例文件数据源kakfa数据源FlinkniuKafkaRecordFlinkniuKafkaRecordSchemaCountryCodeConnect设置并行度为1Flink系列博客 Flink的connect...
  • Flink大数据项目实战

    千人学习 2019-01-18 15:17:04
    本课程基于某电商公司运营实时...通过本课程的学习,既能获得Flink企业级真实项目经验,也能深入掌握Flink的核心理论知识,还能获得Flink在生产环境中安装、部署、监控的宝贵经验,从而一站式全面、深入掌握Flink技术。
  • Flink大数据实时计算系列-Flink的分流器OutputTag 目录 Flink的分流器OutputTagCountryCodeConnectKeyByCountryCountOutTagFlink参考链接Flink系列博客 Flink的分流器OutputTag OutputTag.java /* * Licensed to ...
  • Flink大数据实时计算系列-Flink的operatorState的ListCheckpointed接口使用 目录 Flink的operatorState的ListCheckpointed接口使用ListCheckpointed接口使用案例实战...
  • Flink大数据实时计算系列- Flink的keyBy的数据类型 目录 Flink keyBy的Key类型限制Flink keyBy自定义Key类型案例实战文件数据源FileCountryDictSourceFuntionkakfa数据源...
  • Flink大数据实时计算系列-Flink的累加器和计数器 目录 Flink的累加器和计数器有界数据流无界数据流Flink参考链接Flink系列博客 Flink的累加器和计数器 有界数据流 案例代码 package com.flinkniu.flink.windows; ...
  • Flink大数据实时计算系列-Flink的keyBy算子用法 目录 Flink 的keyBy算子keyBy+connect算子案例实战文件数据源kakfa数据源FlinkniuKafkaRecordFlinkniuKafkaRecordSchemaCountryCodeConnectKeyByFlink系列博客 Flink ...
  • Flink大数据实时计算系列-Flink的checkpoint 目录 Flink的checkpointFlink参考链接Flink系列博客 Flink的checkpoint Flink参考链接 【Flink 官网】Apache Flink 【海牛学院】海牛社区资料 【海牛学院】...
  • Flink大数据实时计算系列-Flink的BroadcastState的使用 目录 Flink的BroadcastState的使用Flink参考链接Flink系列博客 Flink的BroadcastState的使用 Flink参考链接 【Flink 官网】Apache Flink 【海牛学院】海牛...
  • Flink大数据实时计算系列-Flink的CheckPoint原理 Flink分布式环境下的CheckPoint原理 Flink的CheckPoint Flink参考链接 【Flink 官网】Apache Flink 【海牛学院】海牛社区资料 【海牛学院】大数据2020最新版...
  • Flink大数据实时计算系列-Flink读取kafka实现并行RichParallelSource 目录 Flink实现并行的SourceFunctionRichParallelSourceFunctionParallelSourceFunctionFlink案例实战Flink系列博客 Flink实现并行的Source...
  • Flink大数据实时计算系列-Flink的processFunction TimerSerivce删除多余计数器 Flink的processFunction TimerSerivce删除多余计数器 案例代码 package com.flinkniu.flink.windows; import org.apache.flink.api....
  • Flink大数据实时计算系列-Flink的Keyed State之过期超时策略 目录 Flink的Keyed StateFlink的Keyed State代码实战...
  • Flink大数据实时计算系列-Flink的列式格式parquet保存 Flink的列式格式parquet保存 package com.flinkniu.flink.file; import org.apache.flink.api.common.restartstrategy.RestartStrategies; import org.apache...
  • Flink大数据实时计算系列-Flink的列式格式parquet压缩保存 目录 Flink的列式格式parquet压缩保存Flink自定义压缩类实现hive验证parquet格式Flink参考链接Flink系列博客 Flink的列式格式parquet压缩保存 ...
  • Flink大数据实时计算系列-Flink如何调整Task的并行度 setParallelism 方法 setParallelism 分开写 package com.flinkniu.flink.operator; import org.apache.flink.api.java.tuple.Tuple; import org.apache.flink....
  • Flink大数据实时计算系列-Flink的processFunction TimerService结合状态使用 Flink的processFunction TimerService结合状态使用 案例代码 package com.flinkniu.flink.windows; import org.apache.flink.api.common...

空空如也

空空如也

1 2 3 4 5 ... 20
收藏数 25,568
精华内容 10,227
关键字:

flink大数据