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
45
46

use icepick::spec::{Snapshot, Summary};

#[test]
fn test_snapshot_creation() {
    let summary = Summary::builder()
        .set("operation", "append")
        .set("added-files", "1")
        .build();

    let snapshot = Snapshot::builder()
        .with_snapshot_id(1)
        .with_timestamp_ms(1234567890000)
        .with_manifest_list("s3://bucket/metadata/snap-1.avro")
        .with_summary(summary)
        .build()
        .unwrap();

    assert_eq!(snapshot.snapshot_id(), 1);
    assert_eq!(snapshot.timestamp_ms(), 1234567890000);
    assert_eq!(snapshot.manifest_list(), "s3://bucket/metadata/snap-1.avro");
}

#[test]
fn test_snapshot_summary() {
    let summary = Summary::builder()
        .set("operation", "append")
        .set("added-records", "100")
        .build();

    let snapshot = Snapshot::builder()
        .with_snapshot_id(1)
        .with_timestamp_ms(1234567890000)
        .with_manifest_list("s3://bucket/metadata/snap-1.avro")
        .with_summary(summary.clone())
        .build()
        .unwrap();

    assert_eq!(
        snapshot.summary().get("operation"),
        Some(&"append".to_string())
    );
    assert_eq!(
        snapshot.summary().get("added-records"),
        Some(&"100".to_string())
    );
}