micromegas_analytics/
record_batch_transformer.rs

1use anyhow::Result;
2use async_trait::async_trait;
3use datafusion::arrow::array::RecordBatch;
4use std::fmt::Debug;
5
6#[async_trait]
7pub trait RecordBatchTransformer: Send + Sync + Debug {
8    async fn transform(&self, src: RecordBatch) -> Result<RecordBatch>;
9}
10
11#[derive(Debug)]
12pub struct TrivialRecordBatchTransformer {}
13
14#[async_trait]
15impl RecordBatchTransformer for TrivialRecordBatchTransformer {
16    async fn transform(&self, src: RecordBatch) -> Result<RecordBatch> {
17        Ok(src)
18    }
19}