arkflow-plugin 0.1.0

High-performance Rust flow processing engine
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

//! Processor component module
//!
//! The processor component is responsible for transforming, filtering, enriching, and so on.

use std::sync::OnceLock;

pub mod batch;
pub mod json;
pub mod protobuf;
pub mod sql;
mod udf;

lazy_static::lazy_static! {
    static ref INITIALIZED: OnceLock<()> = OnceLock::new();
}

pub fn init() {
    INITIALIZED.get_or_init(|| {
        batch::init();
        json::init();
        protobuf::init();
        sql::init();
    });
}