表规格 语法定义 使用场景 查询表 按历史状态过滤 表规格 eKuiper 流是无界且不可变的，任何新数据都会附加到当前流中进行处理。 Table 用于表示流的当前状态。它可以被认为是流的快照。用户可以使用 table 来保留一批数据进行处理。 在 eKuiper 中不允许单独使用表格。仅建议与流进行 join 操作。join 流时，表格将...

基本概念 基本概念 Name Description Other Group 数据流组，包含多个数据流，一个Group 代表一个数据接入 Group 有ID、Name 等属性 Stream 数据流，一个数据流有具体的流向 Stream 有ID、Name、数据字段等属性 InLongMsg InLong 数据格式，如果从消息队列中直接消费，需要先进行In...

响应式 优点 缺点 说明 注意 代码格式化 lamdba null处理 非阻塞与阻塞 上下文 相关资料 响应式 JetLinks使用reactor (opens new window) 作为响应式编程框架,从网络层(webflux ,vert.x )到持久层(r2dbc ,elastic )全部 封装为非阻塞 ,响应式 调用. 响...

响应式 优点 缺点 说明 注意 代码格式化 lamdba null处理 非阻塞与阻塞 上下文 相关资料 响应式 JetLinks使用reactor 作为响应式编程框架,从网络层(webflux ,vert.x )到持久层(r2dbc ,elastic )全部 封装为非阻塞 ,响应式 调用. 响应式可以理解为观察者模式 ,通过订阅...

响应式 优点 缺点 说明 注意 代码格式化 lamdba null处理 非阻塞与阻塞 上下文 相关资料 响应式 JetLinks使用reactor (opens new window) 作为响应式编程框架,从网络层(webflux ,vert.x )到持久层(r2dbc ,elastic )全部 封装为非阻塞 ,响应式 调用. ...

响应式 优点 缺点 说明 注意 代码格式化 lamdba null处理 非阻塞与阻塞 上下文 相关资料 响应式 JetLinks使用reactor (opens new window) 作为响应式编程框架,从网络层(webflux ,vert.x )到持久层(r2dbc ,elastic )全部 封装为非阻塞 ,响应式 调用. ...

实验特点 将预分区数据流重新解释为被Key化的数据流 实验特点 本节介绍DataStream API中的实验性函数。 实验性函数仍在不断发展，可能不稳定，不完整，或者在未来版本中会发生重大变化。 将预分区数据流重新解释为被Key化的数据流 我们可以将预分区数据流重新解释为被Key化的数据流，以避免混乱。 警告 ：重新解释的数据流...

流模块基础 pipe readable流 创建一个readable流 消耗一个readable流 writable流 创建一个writable流 向一个writable流中写东西 transform流 duplex流 classic流 classic readable流 classic writable流 流模块基础 在nod...

流式写入 获取流式写入器 按行流式写入工作表 流式创建表格 流式插入分页符 流式设置窗格 流式合并单元格 流式设置列宽度 结束流式写入 流式写入 StreamWriter 用于定义流式写入器的数据类型。 type StreamWriter struct { File * File Sh...

基础概念 拓扑（Topologies） 数据流（Streams） 数据源（Spouts） 数据流处理组件（Bolts） 数据流分组（Stream groupings） 可靠性（Reliability） 任务（Tasks） 工作进程（Workers） 基础概念 Storm 系统中包含以下几个基本概念： 拓扑（Topologies） ...