icepick 0.2.0

Experimental Rust client for Apache Iceberg with WASM support for AWS S3 Tables and Cloudflare R2
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
34
35
36
37
38
39
40
41
42
43
44

use icepick::spec::{NestedField, PrimitiveType, Schema, Type};

#[test]
fn test_schema_simple() {
    let fields = vec![
        NestedField::required_field(1, "id".to_string(), Type::Primitive(PrimitiveType::Long)),
        NestedField::required_field(
            2,
            "name".to_string(),
            Type::Primitive(PrimitiveType::String),
        ),
        NestedField::optional_field(
            3,
            "email".to_string(),
            Type::Primitive(PrimitiveType::String),
        ),
    ];

    let schema = Schema::builder()
        .with_fields(fields.clone())
        .build()
        .unwrap();

    assert_eq!(schema.fields().len(), 3);
    assert_eq!(schema.fields()[0].id(), 1);
    assert_eq!(schema.fields()[1].id(), 2);
}

#[test]
fn test_schema_with_struct_type() {
    let schema = Schema::builder()
        .with_schema_id(1)
        .with_fields(vec![NestedField::required_field(
            1,
            "id".to_string(),
            Type::Primitive(PrimitiveType::Long),
        )])
        .build()
        .unwrap();

    assert_eq!(schema.schema_id(), 1);
    let struct_type = schema.as_struct();
    assert_eq!(struct_type.fields().len(), 1);
}