indexlake-datafusion 0.6.0

IndexLake datafusion integration
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
33

mod codec;
mod delete;
mod expr;
mod insert;
mod protobuf;
mod scan;
mod search;
mod table;
mod update;

pub use codec::*;
pub use delete::*;
pub use expr::*;
pub use insert::*;
pub(crate) use protobuf::*;
pub use scan::*;
pub use search::*;
pub use table::*;
pub use update::*;

use arrow::datatypes::Schema;

pub(crate) fn schema_projection_equals(left: &Schema, right: &Schema) -> bool {
    if left.fields.len() != right.fields.len() {
        return false;
    }
    for (left_field, right_field) in left.fields.iter().zip(right.fields.iter()) {
        if left_field.name() != right_field.name() {
            return false;
        }
    }
    true
}