Flink 低级处理函数ProcessFunction ProcessFunction 函数是低阶流处理算子,可以访问流应用程序所有基本构建块: - 事件 (数据流元素) - 状态 (容错和一致性,仅用于keyed stream) - 定时器 (事件时间和处理时间,仅用于keyed stream) 2021-02-23 浏览(713) 评论(0) 阅读全文
Flink Table Api & SQL查询配置(状态清理) 无论Table API和SQL查询的输入是有界批处理输入还是无界流输入,其语义都相同。在许多情况下,对流输入的连续查询能够计算与脱机计算的结果相同的准确结果。但是,这在一般情况下是不可能的,因为连续查询必须限制它们所维护的状态的大小,以避免存储空间用完并能够长时间处理无限制的流数据 2021-01-06 浏览(973) 评论(0) 阅读全文