micromegas-analytics 0.11.0

analytics module of micromegas
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use anyhow::Result;
use async_trait::async_trait;
use datafusion::arrow::array::RecordBatch;
use std::fmt::Debug;

#[async_trait]
pub trait RecordBatchTransformer: Send + Sync + Debug {
    async fn transform(&self, src: RecordBatch) -> Result<RecordBatch>;
}

#[derive(Debug)]
pub struct TrivialRecordBatchTransformer {}

#[async_trait]
impl RecordBatchTransformer for TrivialRecordBatchTransformer {
    async fn transform(&self, src: RecordBatch) -> Result<RecordBatch> {
        Ok(src)
    }
}