大数据-Flink
6 篇
DataStream API DataStream API 是 Flink 的核心层 API,一个 Flink 程序,其实就是对 DataStream 做各种转换。具体来说,代码基本上都由以下几部分构成: 创建一个执 […]
Flink 算子与并行度 Flink 数据并行 每一个算子(Operator)可以包含一个或多个子任务(Operator Subtask),这些子任务在不同的线程、不同的物理机或不同的容器中完全独立地执行。比如 ma […]
Flink On K8s Flink K8S部署 # Flink Kubernetes Operator # 在 Kubernetes 集群上安装证书管理器以启用添加 Webhook 组件(每个 Kubernetes […]
Flink On Yarn 资源管理层面 Resource Manager: 管理整个集群资源,相当于 Master,后续简称 RM。 Node Manager: 管理所在节点的资源,相当于 Worker,后续简称 […]
Flink 什么是flink flink是一个分布式 ,高性能 ,随时可用的以及准确的流处理计算框架 , flink可以对无界数据(流处理)和有界数据(批处理)进行有状态计算(flink天生支持状态计算)的分布式 , […]