const e=JSON.parse('{"key":"v-1e8ca08f","path":"/UserGuide/V1.2.x/User-Manual/Streaming_timecho.html","title":"IoTDB stream processing framework","lang":"en-US","frontmatter":{"description":"The IoTDB stream processing framework allows users to implement customized stream processing logic, which can monitor and capture storage engine changes, transform changed data,...","head":[["link",{"rel":"alternate","hreflang":"zh-cn","href":"https://iotdb.apache.org/zh/UserGuide/V1.2.x/User-Manual/Streaming_timecho.html"}],["meta",{"property":"og:url","content":"https://iotdb.apache.org/UserGuide/V1.2.x/User-Manual/Streaming_timecho.html"}],["meta",{"property":"og:site_name","content":"IoTDB Website"}],["meta",{"property":"og:title","content":"IoTDB stream processing framework"}],["meta",{"property":"og:description","content":"The IoTDB stream processing framework allows users to implement customized stream processing logic, which can monitor and capture storage engine changes, transform changed data,..."}],["meta",{"property":"og:type","content":"article"}],["meta",{"property":"og:locale","content":"en-US"}],["meta",{"property":"og:locale:alternate","content":"zh-CN"}],["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 stream processing framework\\",\\"image\\":[\\"\\"],\\"dateModified\\":\\"2024-03-28T04:48:55.000Z\\",\\"author\\":[]}"]]},"headers":[{"level":2,"title":"Custom stream processing plugin development","slug":"custom-stream-processing-plugin-development","link":"#custom-stream-processing-plugin-development","children":[{"level":3,"title":"Programming development dependencies","slug":"programming-development-dependencies","link":"#programming-development-dependencies","children":[]},{"level":3,"title":"Event-driven programming model","slug":"event-driven-programming-model","link":"#event-driven-programming-model","children":[]},{"level":3,"title":"Custom stream processing plugin programming interface definition","slug":"custom-stream-processing-plugin-programming-interface-definition","link":"#custom-stream-processing-plugin-programming-interface-definition","children":[]}]},{"level":2,"title":"Custom stream processing plugin management","slug":"custom-stream-processing-plugin-management","link":"#custom-stream-processing-plugin-management","children":[{"level":3,"title":"Load plugin statement","slug":"load-plugin-statement","link":"#load-plugin-statement","children":[]},{"level":3,"title":"Delete plugin statement","slug":"delete-plugin-statement","link":"#delete-plugin-statement","children":[]},{"level":3,"title":"View plugin statements","slug":"view-plugin-statements","link":"#view-plugin-statements","children":[]}]},{"level":2,"title":"System preset stream processing plugin","slug":"system-preset-stream-processing-plugin","link":"#system-preset-stream-processing-plugin","children":[{"level":3,"title":"Preset extractor plugin","slug":"preset-extractor-plugin","link":"#preset-extractor-plugin","children":[]},{"level":3,"title":"Preset processor plugin","slug":"preset-processor-plugin","link":"#preset-processor-plugin","children":[]},{"level":3,"title":"Preset connector plugin","slug":"preset-connector-plugin","link":"#preset-connector-plugin","children":[]}]},{"level":2,"title":"Stream processing task management","slug":"stream-processing-task-management","link":"#stream-processing-task-management","children":[{"level":3,"title":"Create a stream processing task","slug":"create-a-stream-processing-task","link":"#create-a-stream-processing-task","children":[]},{"level":3,"title":"Start the stream processing task","slug":"start-the-stream-processing-task","link":"#start-the-stream-processing-task","children":[]},{"level":3,"title":"Stop the stream processing task","slug":"stop-the-stream-processing-task","link":"#stop-the-stream-processing-task","children":[]},{"level":3,"title":"Delete stream processing tasks","slug":"delete-stream-processing-tasks","link":"#delete-stream-processing-tasks","children":[]},{"level":3,"title":"Display stream processing tasks","slug":"display-stream-processing-tasks","link":"#display-stream-processing-tasks","children":[]},{"level":3,"title":"Stream processing task running status migration","slug":"stream-processing-task-running-status-migration","link":"#stream-processing-task-running-status-migration","children":[]}]},{"level":2,"title":"authority management","slug":"authority-management","link":"#authority-management","children":[{"level":3,"title":"Stream processing tasks","slug":"stream-processing-tasks","link":"#stream-processing-tasks","children":[]},{"level":3,"title":"Stream processing task plugin","slug":"stream-processing-task-plugin","link":"#stream-processing-task-plugin","children":[]}]},{"level":2,"title":"Configuration parameters","slug":"configuration-parameters","link":"#configuration-parameters","children":[]}],"git":{"createdTime":1711601335000,"updatedTime":1711601335000,"contributors":[{"name":"wanghui42","email":"105700158+wanghui42@users.noreply.github.com","commits":1}]},"readingTime":{"minutes":19.31,"words":5794},"filePathRelative":"UserGuide/V1.2.x/User-Manual/Streaming_timecho.md","localizedDate":"March 28, 2024","autoDesc":true}');export{e as data};