240 发简信
IP属地:北京
  • Resize,w 360,h 240
    集合

    一、集合大纲 1.集合和数组的区别: 2.Collection集合的方法: 3.常用集合的分类:Collection 接口的接口 对象的集合(单...

  • Streaming -- Operators -- Windows

    窗口是处理无限流的核心。Windows将流分割成有限大小的"桶",我们可以在这些桶上进行计算。本文档主要介绍在Flink中如何执行窗口,以及程序...

  • Streaming -- Operators -- Overview

    操作符将一个或多个数据令转换为一个新的数据令。程序可以将多种转换组合成复杂的数据流拓扑。 本节将介绍基本的转换、应用这些转换后的有效物理分区以及...

  • Streaming -- State & Fault Tolerance -- Custom Serialization for Managed State

    此页面的目标是为需要使用自定义状态序列化的用户提供指导方针,介绍了如何提供自定义状态序列化器,以及实现允许状态模式演化的序列化器的指导方针和最佳...

  • Streaming -- State & Fault Tolerance -- State Schema Evolution

    Apache Flink流媒体应用程序通常设计为无限期运行或长时间运行。与所有长期运行的服务一样,需要更新应用程序以适应不断变化的需求。这同样适...

  • Streaming -- State & Fault Tolerance -- State Backends

    Flink提供了不同的状态后端,用于指定状态存储的方式和位置。 状态可以位于Java的堆或堆外。根据您的状态后端,Flink还可以管理应用程序的...

  • Streaming -- State & Fault Tolerance -- Checkpointing

    Flink中的每个函数和运算符都可以是有状态的(有关详细信息,请参见使用状态[https://ci.apache.org/projects/fl...

  • Streaming -- State & Fault Tolerance -- The Broadcast State Pattern

    Working with State[https://www.jianshu.com/p/fa59ed63cf62]描述了操作符的状态,在恢复时...

  • Streaming -- State & Fault Tolerance -- Working with State

    本文档解释了在开发应用程序时如何使用Flink的状态抽象。 Keyed State and Operator State 在Flink中有两种基...