小小千想和您聊一聊

当前位置: 首页> 视频教程> 2019大数据之快速入门Flink

2019大数据之快速入门Flink高级

   评分9.4

34节课

12411人已学

下载本章视频你能学到什么?

熟悉Flink核心流式数据流引擎,在流式引擎的基础上实现批处理。

千锋大数据官方①群(857910996)——猛戳进入


课程介绍

Flink是一个开源的分布式流式和批处理平台;Flink核心是流式数据流引擎,然后在流式引擎的基础上实现批处理。和spark正好相反,spark核心是批处理引擎,然后在批处理引擎的基础上实现流式处理。

章节目录

第1节 Flink课程介绍 第18节 Scala实现WordCount-初始化环境
第2节 学习要求 第19节 Scala实现WordCount-实现聚合过程
第3节 计算引擎的四个时代 第20节 Scala实现WordCount-执行应用程序
第4节 Flink的技术特点 第21节 Java实现批处理WordCount-初始化对象
第5节 Flink的生态圈和架构图 22 Java实现批处理WordCount-实现聚合
第6节 Flink的基本组件 第23节 Java实现批处理WordCount-结果展示
第7节 Flink的流处理与批处理 第24节 Scala实现批处理WordCount-实现过程
第8节 Flink的应用场景 第25节 流式处理和批处理的区别
第9节 Flink与其它实时计算引擎比较 第26节 Flink集群部署内容介绍
第10节 开发环境 第27节 资源调度系统介绍
第11节 WordCount需求分析 28 Flink Local模式安装和启动
第12节 创建Maven项目 29 查看Flink WebUI界面
第13节 关于窗口操作的理解 30 Standalone模式介绍和安装
第14节 开发步骤简介 31 Standalone集群启动和查看WebUI
第15节 Java实现WordCount-初始化环境 32 关于集群配置的几个重要参数介绍
第16节 Java实现WordCount-实现聚合过程 33 Flink集群节点的重启和容错
第17节 Java实现WordCount-执行应用程序

  • Scala系列之对象

    在Scala中没有静态方法和静态字段,但是可以使用object这个语法结构来达到同样的目的。

    456
  • Scala系列之抽象类

    如果某个类至少存在一个抽象方法或一个抽象字段,则该类必须声明为abstract。

    510
  • Scala系列之闭包

    闭包通常来讲可以简单的认为是可以访问一个函数里面局部变量的另外一个函数。

    567
  • Scala系列之闭包

    闭包是一个函数,返回值依赖于声明在函数外部的一个或多个变量。

    765
  • Scala系列之抽象类

    如果某个类至少存在一个抽象方法或一个抽象字段,则该类必须声明为abstract。

    733
  • Scala系列之映射Map

    Scala系列之映射Map

    867
  • Scala系列之集合操作函数

    系列之集合操作函数

    1086
  • Scala系列之List、set、元祖

    映射是K/V对偶的集合,对偶是元组的最简单形式,元组可以装着多个不同类型的值,是不同类型的值的聚集。

    1145
  • Hive分区和分桶

    当单个表数据量越来越大的时候,hive查询通常会全表扫描,这将会浪费我们不关心数据的扫描,浪费大量时间。从而hive引出分区概念partition

    825
  • 大数据编程之UDF函数

     UDF:user difine function,用户自定义函数,一对一。常用 udaf:user define aggregate function,用户自定义聚合函数,多对一。 udtf:user define table_generate function,用户自定义表生成函数,一对多。

    1103

他们都在看