登录免费注册



Flink源码及原理剖析

首页  思维导图  详情



Flink源码及原理剖析

2023-03-09 16:56:44   0  举报





仅支持查看

AI智能生成

flink知识框架，学习内容

flink

学习框架图

模版推荐

作者其他创作

大纲/内容

应用容错

监控

metrics

流批一体

Flink-SQL

Flink-ML

一个实战的案例开始

简单的例子引出flink编程的五大部分

一个执行环境

接入数据流（source）

对数据流的操作(transformations)

输出（sink）

触发程序执行（execute）

实际项目使用讲解

讲清楚我们是如何使用的

基础

Flink架构

Flink Client

jobmanager

启动流程

taskmanager

启动流程

部署模式

图的转换

StreamGraph

JobGraph

ExecutionGraph

作业

作业调度

作业执行

资源管理

运行时原理

集群资源管理

task

subtask

slot资源共享

核心概念

Task

subTask

slot

slotSharingGroup

operator chain

            核心篇<br>（结合DataStream API详解<br>每部分从作用和源码讲）<br>

环境对象

StreamExecutionEnvironment

作用

源码

通过源码看核心配置

ExecutionConfig

CheckpointConfig

List<Transformation<?>>

StateBackend

TimeCharacteristic

    数据源<br>source API<br>

File-based

socket-based

collection-based

custom

addSource

Connectors

Kafka

Hybrid source

.........

数据转换<br>(transformations)

Operators

基本的

Map

FlatMap

Filter

KeyBy

Reduce

时间与窗口

window

windowAll

Window Apply

Window reduce

窗口分类及用途

Process Function

其他特殊转换

        旁路输出<br>（Side Outputs）

作用-使用场景

源码

SInk

execute

分布式ID

作用

类型与序列化

高阶

处理函数

ProcessFunction

KeyedProcessFunction

窗口处理函数

多流转换

合并及关联

分流

filter

侧输出流

合流

Union

Connect

join

Window Join

Interval Join

状态

状态原理

状态类型

状态存储

状态持久化

状态过期

容错机制

内存管理

内存模型

网络缓冲器

NetworkBuffer

数据交换

数据传递

网络通信

自由主题

Java并发实现原理 JDK源码剖析

 Collect

Get Started

Java并发实现原理 JDK源码剖析

 Collect

Get Started

flink源码笔记

 Collect

Get Started

Flink内部原理

 Collect

Get Started

Netty源码剖析













评论

0 条评论

下一页



图形选择

思维导图

主题

补充说明

AI生成





修改AI描述

去编辑

重新生成

提示 

关闭后当前内容将不会保存，是否继续？

取消

确定

Document