时间：   |   分类：   | 字数： 531 字 | 阅读约： 2分钟

Flink 安装和部署

Flink支持多种安装模式

  • local（本地）：单机模式，一般本地开发调试使用
  • StandAlone 独立模式：Flink自带集群，自己管理资源调度，生产环境也会有所应用
  • Yarn模式：计算资源统一由Hadoop YARN管理，生产环境应用较多

第 1 节 环境准备工作

1.1 基础环境

  • jdk1.8及以上【配置JAVA_HOME环境变量】

阅读全文 »

时间：   |   分类：   | 字数： 1692 字 | 阅读约： 4分钟

Flink 体系结构

第 1 节 Flink的重要角色

image-20200731000902936

Flink是非常经典的Master/Slave结构实现，JobManager是Master，TaskManager是Slave。

阅读全文 »

时间：   |   分类：   | 字数： 461 字 | 阅读约： 1分钟

Flink 快速应用

通过一个单词统计的案例，快速上手应用Flink，进行流处理（Streaming）和批处理（Batch）

示例代码： https://gitee.com/ixinglan/flink-demo.git

第 1 节 单词统计案例（批数据）

1.1 需求

​ 统计一个文件中各个单词出现的次数，把统计结果输出到文件

阅读全文 »

时间：   |   分类：   | 字数： 2001 字 | 阅读约： 4分钟

Flink 概述

​ Apache Flink是一个框架和分布式处理引擎，用于对无界和有界数据流进行有状态计算。Flink被设计在所有常见的集群环境中运行，以内存执行速度和任意规模来执行计算。

阅读全文 »
0%