rlink 0.6.16

High performance Stream Processing Framework
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
25
26
27
28
29
30
31
32

use crate::core::data_types::{Field, Schema};

#[derive(Clone, Debug)]
pub enum ColumnLocate {
    Index(usize),
    Name(String),
}

impl ColumnLocate {
    pub fn to_column<'a>(&self, schema: &'a Schema) -> (usize, &'a Field) {
        match self {
            Self::Index(index) => (*index, schema.field(*index)),
            Self::Name(name) => schema.column_with_name(name.as_str()).unwrap(),
        }
    }
}

pub trait ColumnLocateBuilder {
    fn build(&self) -> ColumnLocate;
}

impl ColumnLocateBuilder for usize {
    fn build(&self) -> ColumnLocate {
        ColumnLocate::Index(*self)
    }
}

impl<'a> ColumnLocateBuilder for &'a str {
    fn build(&self) -> ColumnLocate {
        ColumnLocate::Name(self.to_string())
    }
}