ICode9

精准搜索请尝试: 精确搜索
首页 > 编程语言> 文章详细

Apache Flink系列-⑤应用程序构建块

2022-05-01 00:34:39  阅读:161  来源: 互联网

标签:状态 函数 Flink 应用程序 构建 Apache


应用程序构建块

有状态函数为构建事件驱动的应用程序提供了一个框架。这里,我们将解释有状态函数体系结构的重要方面。

事件入口

有状态函数应用程序直接位于事件驱动的空间中,因此自然要从将事件引入系统开始。

Apache Flink系列-⑤应用程序构建块

 

在有状态函数中,将记录接收到系统中的组件称为事件入口。这可以是任何内容,从卡夫卡主题到消息队列,再到http请求——任何可以将数据输入系统并触发初始函数开始计算的内容。

有状态函数

图的核心是同名的有状态函数。

Apache Flink系列-⑤应用程序构建块

 

把这些当做你服务的基石。它们可以任意地相互传递消息,这是该框架摆脱传统的流处理世界观的一种方式。这些函数不需要建立静态数据流DAG,而是可以以任意的、可能是循环的、甚至是往返的方式相互通信。

如果您熟悉actor编程,那么它在组件之间动态传递消息的能力上确实有一些相似之处。然而,有一些显著的差异。

持续状态

首先,所有函数都有本地嵌入状态,称为持久状态。

Apache Flink系列-⑤应用程序构建块

 

在失败的情况下,将回滚整个世界状态(持久状态和消息),以模拟完全无故障的执行。

这些保证不需要数据库,相反,有状态函数利用了Apache Flink经验证的快照机制。

事件出口

最后,应用程序可以通过事件出口将数据输出到外部系统。

Apache Flink系列-⑤应用程序构建块

 

当然,函数可以执行任意计算,并且可以做任何他们喜欢的事情,包括进行RPC调用和连接到其他系统。通过使用事件出口,应用程序可以利用构建在Apache Flink连接器生态系统之上的预构建集成。

Apache Flink系列-⑤应用程序构建块

标签:状态,函数,Flink,应用程序,构建,Apache
来源: https://www.cnblogs.com/suprising/p/16211940.html

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有