一、集合大纲 1.集合和数组的区别: 2.Collection集合的方法: 3.常用集合的分类:Collection 接口的接口 对象的集合(单...
窗口是处理无限流的核心。Windows将流分割成有限大小的"桶",我们可以在这些桶上进行计算。本文档主要介绍在Flink中如何执行窗口,以及程序...
操作符将一个或多个数据令转换为一个新的数据令。程序可以将多种转换组合成复杂的数据流拓扑。 本节将介绍基本的转换、应用这些转换后的有效物理分区以及...
此页面的目标是为需要使用自定义状态序列化的用户提供指导方针,介绍了如何提供自定义状态序列化器,以及实现允许状态模式演化的序列化器的指导方针和最佳...
Apache Flink流媒体应用程序通常设计为无限期运行或长时间运行。与所有长期运行的服务一样,需要更新应用程序以适应不断变化的需求。这同样适...
Flink提供了不同的状态后端,用于指定状态存储的方式和位置。 状态可以位于Java的堆或堆外。根据您的状态后端,Flink还可以管理应用程序的...
Flink中的每个函数和运算符都可以是有状态的(有关详细信息,请参见使用状态[https://ci.apache.org/projects/fl...
Working with State[https://www.jianshu.com/p/fa59ed63cf62]描述了操作符的状态,在恢复时...
本文档解释了在开发应用程序时如何使用Flink的状态抽象。 Keyed State and Operator State 在Flink中有两种基...