大数据-Flink

待续。。。

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天生支持状态计算）的分布式 , […]