Quick Start #[https://paimon.apache.org/docs/0.9/spark/quick-start/#quick-start] Prepar...
发简信
IP属地：湖北
-
-
-
概念 - 规范 - Manifest
Manifest Manifest List #[https://paimon.apache.org/docs/0.9/concepts/spec/manifest/#man...
-
概念 - 规范 - Schema
Schema 该Schema文件的版本从 0 开始计数，目前保留了所有版本的Schema文件。可能存在依赖旧Schema版本的旧文件，因此删除此类文件时应谨慎行事。 Sche...
-
概念 - 规范 - 概述规范概述 这是 Paimon 表格格式的规范说明，此文档对 Paimon 的底层文件结构和设计进行了标准化处理。 术语 Schema: 字段、主键定义、分区键定义及选项。 S...
-
-
-
-
-
Streaming -- Operators -- Windows
窗口是处理无限流的核心。Windows将流分割成有限大小的"桶"，我们可以在这些桶上进行计算。本文档主要介绍在Flink中如何执行窗口，以及程序员如何从它提供的功能中获得最大...
-
Streaming -- Operators -- Overview
操作符将一个或多个数据令转换为一个新的数据令。程序可以将多种转换组合成复杂的数据流拓扑。 本节将介绍基本的转换、应用这些转换后的有效物理分区以及对Flink s操作符链接的深...
-
Streaming -- State & Fault Tolerance -- Custom Serialization for Managed State
此页面的目标是为需要使用自定义状态序列化的用户提供指导方针，介绍了如何提供自定义状态序列化器，以及实现允许状态模式演化的序列化器的指导方针和最佳实践。 如果您只是使用Flin...
-
Streaming -- State & Fault Tolerance -- State Schema Evolution
Apache Flink流媒体应用程序通常设计为无限期运行或长时间运行。与所有长期运行的服务一样，需要更新应用程序以适应不断变化的需求。这同样适用于应用程序所针对的数据模式;...
-
Streaming -- State & Fault Tolerance -- State Backends
Flink提供了不同的状态后端，用于指定状态存储的方式和位置。 状态可以位于Java的堆或堆外。根据您的状态后端，Flink还可以管理应用程序的状态，这意味着Flink处理内...
-
Streaming -- State & Fault Tolerance -- Checkpointing
Flink中的每个函数和运算符都可以是有状态的（有关详细信息，请参见使用状态[https://ci.apache.org/projects/flink/flink-docs-...
-
Streaming -- State & Fault Tolerance -- The Broadcast State Pattern
Working with State[https://www.jianshu.com/p/fa59ed63cf62]描述了操作符的状态，在恢复时，该状态是均匀地分布在操作符的...
