arkflow_plugin/processor/
mod.rs

1//! Processor component module
2//!
3//! The processor component is responsible for transforming, filtering, enriching, and so on.
4
5use std::sync::OnceLock;
6
7pub mod batch;
8pub mod json;
9pub mod protobuf;
10pub mod sql;
11mod udf;
12
13lazy_static::lazy_static! {
14    static ref INITIALIZED: OnceLock<()> = OnceLock::new();
15}
16
17pub fn init() {
18    INITIALIZED.get_or_init(|| {
19        batch::init();
20        json::init();
21        protobuf::init();
22        sql::init();
23    });
24}