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

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

工作流管理 创建工作流 数据集成 创建集成节点 编辑集成节点 数据清洗 创建清洗节点 编辑清洗节点 数据萃取 创建萃取节点 编辑萃取节点 数据导出 创建导出节点 编辑导出节点 ONE ID 标签计算 创建标签节点 编辑标签节点 数据注销 Python 执行 群组计算 工作流明细 工作流导入导出 工作流管理 完...

流式计算 创建流式计算 流式计算的 partition 流式计算读取历史数据 删除流式计算 展示流式计算 流式计算的触发模式 流式计算的窗口关闭 流式计算的过期数据处理策略 流式计算 创建流式计算 CREATE STREAM [ IF NOT EXISTS ] stream_name [ stream_options ] IN...

流式处理 流处理的特点 边缘流处理 有状态的流处理 流式处理 流数据是随着时间的推移而产生的数据元素序列。流处理是对流数据的处理。与批处理不同，流数据会在产生后立即被逐一处理。 流处理的特点 流处理具有以下特点。 无界数据：流数据是一种不断增长的、无限的数据集，不能作为一个整体来操作。 无界的数据处理：由于适用于无界数据，流处理本身也是无...

源 Sources 定义和运行 解码 数据结构 流和表 更多信息 源 Sources 源（source）用于从外部系统中读取数据。数据源既可以是无界的流式数据，即流；也可以是有界的批量数据，即表。在规则中使用时，至少有一个源必须为流。 源定义了如何连接到外部资源，然后采用流式方式获取数据。获取数据后，通常源还会根据定义的数据模型进行数据解码...

Dashboard 指引 用户登录 数据接入 数据流Group 信息 接入要求 Group 信息 接入规模 数据流 基础信息 数据来源 数据信息 数据流向 我的申请 申请数据接入详情 数据消费 消费信息 Dashboard 指引 用户登录 需系统使用用户输入账号名称和密码，默认账号是admin inlong 。 ...

Dashboard 指引 用户登录 数据接入 数据流Group 信息 接入要求 Group 信息 接入规模 数据流 基础信息 数据来源 数据信息 数据流向 我的申请 申请数据接入详情 数据消费 消费信息 Dashboard 指引 用户登录 需系统使用用户输入账号名称和密码，默认账号是admin inlong 。 ...

Dashboard 指引 用户登录 数据接入 数据流Group 信息 接入要求 Group 信息 接入规模 数据流 基础信息 数据来源 数据信息 数据流向 我的申请 申请数据接入详情 数据消费 消费信息 Dashboard 指引 用户登录 需系统使用用户输入账号名称和密码，默认账号是admin inlong 。 ...

global_streaming_hadr_rto_and_rpo_stat global_streaming_hadr_rto_and_rpo_stat global_streaming_hadr_rto_and_rpo_stat视图显示流式容灾的主数据库实例和备数据库实例日志流控信息（只可在主数据库实例的数据库主节点使用，数据库备节点以及备数据库实...