低级处理函数ProcessFunction Flink

低级处理函数ProcessFunction

ProcessFunction 函数是低阶流处理算子,可以访问流应用程序所有基本构建块: - 事件 (数据流元素) - 状态 (容错和一致性,仅用于keyed stream) - 定时器 (事件时间和处理时间,仅用于keyed stream)
阅读全文
Table Api & SQL查询配置(状态清理) Flink

Table Api & SQL查询配置(状态清理)

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