const e=JSON.parse('{"key":"v-e988dc84","path":"/zh/UserGuide/V1.2.x/User-Manual/Streaming.html","title":"IoTDB 流处理框架","lang":"zh-CN","frontmatter":{"description":"IoTDB 流处理框架允许用户实现自定义的流处理逻辑，可以实现对存储引擎变更的监听和捕获、实现对变更数据的变形、实现对变形后数据的向外推送等逻辑。 我们将一个数据流处理任务称为 Pipe。一个流处理任务（Pipe）包含三个子任务： 抽取（Extract）; 处理（Process）; 发送（Connect）; 流处理框架允许用户使用 Java 语言自定义...","head":[["link",{"rel":"alternate","hreflang":"en-us","href":"https://iotdb.apache.org/UserGuide/V1.2.x/User-Manual/Streaming.html"}],["meta",{"property":"og:url","content":"https://iotdb.apache.org/zh/UserGuide/V1.2.x/User-Manual/Streaming.html"}],["meta",{"property":"og:site_name","content":"IoTDB Website"}],["meta",{"property":"og:title","content":"IoTDB 流处理框架"}],["meta",{"property":"og:description","content":"IoTDB 流处理框架允许用户实现自定义的流处理逻辑，可以实现对存储引擎变更的监听和捕获、实现对变更数据的变形、实现对变形后数据的向外推送等逻辑。 我们将一个数据流处理任务称为 Pipe。一个流处理任务（Pipe）包含三个子任务： 抽取（Extract）; 处理（Process）; 发送（Connect）; 流处理框架允许用户使用 Java 语言自定义..."}],["meta",{"property":"og:type","content":"article"}],["meta",{"property":"og:locale","content":"zh-CN"}],["meta",{"property":"og:locale:alternate","content":"en-US"}],["meta",{"property":"og:updated_time","content":"2024-03-28T04:48:55.000Z"}],["meta",{"property":"article:modified_time","content":"2024-03-28T04:48:55.000Z"}],["script",{"type":"application/ld+json"},"{\\"@context\\":\\"https://schema.org\\",\\"@type\\":\\"Article\\",\\"headline\\":\\"IoTDB 流处理框架\\",\\"image\\":[\\"\\"],\\"dateModified\\":\\"2024-03-28T04:48:55.000Z\\",\\"author\\":[]}"]]},"headers":[{"level":2,"title":"自定义流处理插件开发","slug":"自定义流处理插件开发","link":"#自定义流处理插件开发","children":[{"level":3,"title":"编程开发依赖","slug":"编程开发依赖","link":"#编程开发依赖","children":[]},{"level":3,"title":"事件驱动编程模型","slug":"事件驱动编程模型","link":"#事件驱动编程模型","children":[]},{"level":3,"title":"自定义流处理插件编程接口定义","slug":"自定义流处理插件编程接口定义","link":"#自定义流处理插件编程接口定义","children":[]}]},{"level":2,"title":"自定义流处理插件管理","slug":"自定义流处理插件管理","link":"#自定义流处理插件管理","children":[{"level":3,"title":"加载插件语句","slug":"加载插件语句","link":"#加载插件语句","children":[]},{"level":3,"title":"删除插件语句","slug":"删除插件语句","link":"#删除插件语句","children":[]},{"level":3,"title":"查看插件语句","slug":"查看插件语句","link":"#查看插件语句","children":[]}]},{"level":2,"title":"系统预置的流处理插件","slug":"系统预置的流处理插件","link":"#系统预置的流处理插件","children":[{"level":3,"title":"预置 extractor 插件","slug":"预置-extractor-插件","link":"#预置-extractor-插件","children":[]},{"level":3,"title":"预置 processor 插件","slug":"预置-processor-插件","link":"#预置-processor-插件","children":[]},{"level":3,"title":"预置 connector 插件","slug":"预置-connector-插件","link":"#预置-connector-插件","children":[]}]},{"level":2,"title":"流处理任务管理","slug":"流处理任务管理","link":"#流处理任务管理","children":[{"level":3,"title":"创建流处理任务","slug":"创建流处理任务","link":"#创建流处理任务","children":[]},{"level":3,"title":"启动流处理任务","slug":"启动流处理任务","link":"#启动流处理任务","children":[]},{"level":3,"title":"停止流处理任务","slug":"停止流处理任务","link":"#停止流处理任务","children":[]},{"level":3,"title":"删除流处理任务","slug":"删除流处理任务","link":"#删除流处理任务","children":[]},{"level":3,"title":"展示流处理任务","slug":"展示流处理任务","link":"#展示流处理任务","children":[]},{"level":3,"title":"流处理任务运行状态迁移","slug":"流处理任务运行状态迁移","link":"#流处理任务运行状态迁移","children":[]}]},{"level":2,"title":"权限管理","slug":"权限管理","link":"#权限管理","children":[{"level":3,"title":"流处理任务","slug":"流处理任务","link":"#流处理任务","children":[]},{"level":3,"title":"流处理任务插件","slug":"流处理任务插件","link":"#流处理任务插件","children":[]}]},{"level":2,"title":"配置参数","slug":"配置参数","link":"#配置参数","children":[]}],"git":{"createdTime":1711601335000,"updatedTime":1711601335000,"contributors":[{"name":"wanghui42","email":"105700158+wanghui42@users.noreply.github.com","commits":1}]},"readingTime":{"minutes":21.94,"words":6581},"filePathRelative":"zh/UserGuide/V1.2.x/User-Manual/Streaming.md","localizedDate":"2024年3月28日","autoDesc":true}');export{e as data};