搜索结果
查询Tags标签: parallelism,共有 3条记录-
Flink核心抽象三数据转换
Transformation在Flink中被称为数据转换,Transformation面向Flink内核,DataStream面向开发者。 Transformation有两大类,物理Transformation和虚拟Transformation Transformation是顶层的抽象,在所有物理的Transformation都是继承PhysicalTransformation 其他的类型的…
2021/12/3 6:09:04 人评论 次浏览 -
Flink核心抽象三数据转换
Transformation在Flink中被称为数据转换,Transformation面向Flink内核,DataStream面向开发者。 Transformation有两大类,物理Transformation和虚拟Transformation Transformation是顶层的抽象,在所有物理的Transformation都是继承PhysicalTransformation 其他的类型的…
2021/12/3 6:09:04 人评论 次浏览 -
Flink 1.12.2 源码分析 : 官方 Flink Plan Visualizer 使用.
一. 前言 官方提供了获取执行计划的WEB页面. 入口 : https://flink.apache.org/visualizer/二. 使用 2.1. 获取执行计划json字符串. 获取执行计划的json字符串很简单. 就是在代码里面加一个输出就行了. System.out.println(env.getExecutionPlan());在这里插入图片描述 获…
2021/4/18 1:25:22 人评论 次浏览