micromegas-analytics 0.2.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
20
21
22
23
24

use datafusion::arrow::{array::RecordBatch, datatypes::Schema};
use std::sync::Arc;

/// Record batches + schema
pub struct Answer {
    pub schema: Arc<Schema>,
    pub record_batches: Vec<RecordBatch>,
}

impl Answer {
    pub fn new(schema: Arc<Schema>, record_batches: Vec<RecordBatch>) -> Self {
        Self {
            schema,
            record_batches,
        }
    }

    pub fn from_record_batch(rc: RecordBatch) -> Self {
        Self {
            schema: rc.schema(),
            record_batches: vec![rc],
        }
    }
}