流规格 数据类型 语言定义 Strict Validation Schema-less 流 二进制流 流规格 数据类型 在 Kuiper 中，每个列或表达式都有一个相关的数据类型。 数据类型描述（约束）该类型的列可以容纳的一组值或该类型可以产生的表达式。 以下是支持的数据类型的列表。 # 数据类型 说明 1 bigint 2 fl...

v1.17.0 Release Notes 功能列表 业务变更声明 版本升级过程 数据库备份 升级操作 安装方式： All in One 一键安装模式 或 基于现有 Kubernetes 安装 安装方式： 基于 Helm 命令安装 v1.17.0 Release Notes 2023 年 4 月 4 日，Zadig 正式发布 v...

Sonic Standard模式实现原理 一，无缓存模式 二，有缓存模式： 1，完全缓存： 2，局部刷新： 3，模版变更 Sonic Standard模式实现原理 从前面介绍的sonic的基本原理可以知道，sonic分为Quick模式和Standard模式。本文介绍Standard模式的基本实现原理。根据本地缓存的数据情况可以将Quick...

gs_hadr_local_rto_and_rpo_stat gs_hadr_local_rto_and_rpo_stat gs_hadr_local_rto_and_rpo_stat视图显示流式容灾的主数据库实例和备数据库实例日志流控信息（只可在主数据库实例的数据库主节点使用，数据库备节点以及备数据库实例均上不可获取到统计信息）。 表 1 gs_...

Kafka 示例 环境部署 安装 InLong 安装 ClickHouse 安装Kafka 集群初始化 创建集群标签 注册 Kafka 集群 注册 Clickhouse 数据节点 任务创建 新建数据流组 新建数据流 新建数据源 新建数据目标 审批数据流 测试数据 发送数据 数据验证 常见问题 任务配置失败 发送数据生成脚本...

Kafka 示例 环境部署 安装 InLong 安装 ClickHouse 安装Kafka 集群初始化 创建集群标签 注册 Kafka 集群 注册 Clickhouse 数据节点 任务创建 新建数据流组 新建数据流 新建数据源 新建数据目标 审批数据流 测试数据 发送数据 数据验证 常见问题 任务配置失败 发送数据生成脚本...

Kafka 示例 环境部署 安装 InLong 安装 ClickHouse 安装Kafka 集群初始化 创建集群标签 注册 Kafka 集群 注册 Clickhouse 数据节点 任务创建 新建数据流组 新建数据流 新建数据源 新建数据目标 审批数据流 测试数据 发送数据 数据验证 常见问题 任务配置失败 发送数据生成脚本...

流规格 数据类型 语言定义 共享源实例 Strict Validation Schema-less 流 二进制流 流规格 数据类型 在 eKuiper 中，每个列或表达式都有一个相关的数据类型。 数据类型描述（约束）该类型的列可以容纳的一组值或该类型可以产生的表达式。 以下是支持的数据类型的列表。 # 数据类型 说明 ...

IO InputStream / OutputStream Reader / Writer 同步和异步 小结 读后有收获可以支付宝请作者喝咖啡： IO IO是指Input/Output，即输入和输出。以内存为中心： Input指从外部读入数据到内存，例如，把文件从磁盘读取到内存，从网络读取数据到内存等等。 Output指把数据从内存...

mKCP 协议 版本 依赖 底层协议 函数 通讯过程 数据格式 数据包 数据片段 确认片段 心跳片段 mKCP 协议 mKCP 是流式传输协议，由 KCP 协议 修改而来，可以按顺序传输任意的数据流。 版本 mKCP 没有版本号，不保证版本之间兼容性。 依赖 底层协议 mKCP 是一个基于 UDP 的协议，所有通讯...