数据工匠记 | 一个程序员的个人博客

低级处理函数ProcessFunction

ProcessFunction 函数是低阶流处理算子，可以访问流应用程序所有基本构建块： - 事件 (数据流元素) - 状态 (容错和一致性，仅用于keyed stream) - 定时器 (事件时间和处理时间，仅用于keyed stream)

2021-02-23 浏览(713) 评论(0)

Akka提供了一种叫做stash的机制，用于对于Akka中消息状态的来回切换

2021-01-13 浏览(535) 评论(0)

无论Table API和SQL查询的输入是有界批处理输入还是无界流输入，其语义都相同。在许多情况下，对流输入的连续查询能够计算与脱机计算的结果相同的准确结果。但是，这在一般情况下是不可能的，因为连续查询必须限制它们所维护的状态的大小，以避免存储空间用完并能够长时间处理无限制的流数据

2021-01-06 浏览(973) 评论(0)