赞
踩
作者:禅与计算机程序设计艺术
Apache Flink是一个开源的分布式计算框架,由Apache软件基金会(ASF)托管,是目前流处理领域最热门的项目之一,具有高吞吐量、低延迟、容错性强等优点。它是一个基于Java的分布式计算平台,提供用于实时数据分析、事件处理、批处理和机器学习等多种应用场景。它的运行环境支持本地模式(单机部署),YARN模式(Hadoop YARN集成)和Kubernetes模式(容器化部署)。
Apache Flink的架构如图所示:
从整体架构图中可以看出,Flink有四个主要模块:
Watermark 是 Apache Flink 提供的一个重要概念,它是一种特殊的数据类型,用于标识事件时间界限。每一个 Watermark 表示的是当前已知的所有消息中最大的那个消息的时间戳,即 watermark time 的值,它也被称为 event t
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。