108 releases (44 breaking)

new 0.45.5 Oct 24, 2024
0.44.1 Oct 7, 2024
0.38.0 Jul 22, 2024
0.28.0 Mar 25, 2024
0.1.0 Mar 5, 2022

#86 in Encoding

Download history 83732/week @ 2024-07-09 90337/week @ 2024-07-16 84985/week @ 2024-07-23 85442/week @ 2024-07-30 85799/week @ 2024-08-06 110009/week @ 2024-08-13 115168/week @ 2024-08-20 95678/week @ 2024-08-27 113799/week @ 2024-09-03 122612/week @ 2024-09-10 111991/week @ 2024-09-17 134269/week @ 2024-09-24 129450/week @ 2024-10-01 153114/week @ 2024-10-08 144343/week @ 2024-10-15 243264/week @ 2024-10-22

698,534 downloads per month
Used in 12 crates (3 directly)

Apache-2.0

71KB
1.5K SLoC

substrait-rs

substrait

crates.io docs.rs

Rust crate for Substrait: Cross-Language Serialization for Relational Algebra.

Documentation


lib.rs:

Substrait: Cross-Language Serialization for Relational Algebra

Serialization and deserialization

This crate provides generated types to serialize and deserialize Substrait data.

Protobuf

Protobuf serialization and deserialization are provided via [prost] in the [proto] module.

Example

Serialize and deserialize a plan

use prost::Message;
use substrait::proto::Plan;

let plan = Plan::default();

// Serialize the plan
let encoded = plan.encode_to_vec();

// Deserialize the buffer to a Plan
let decoded = Plan::decode(encoded.as_slice())?;

assert_eq!(plan, decoded);

Serde support

The serde feature generates serde implementations that match the Protobuf JSON Mapping via pbjson.

Example
Deserialize a plan version using the serde feature
use substrait::proto::Version;

let version_json = r#"{
  "minorNumber": 21
}"#;

let version = serde_json::from_str::<Version>(version_json)?;
assert_eq!(
  version,
  Version {
    minor_number: 21,
    ..Default::default()
  }
);

Text

Substrait defines a YAML schema for extensions. Types with serialization and deserialization support for these are provided via typify in the [text] module.

Example

Read a simple extension

use substrait::text::simple_extensions::SimpleExtensions;

let simple_extension_yaml = r#"
%YAML 1.2
---
scalar_functions:
  -
    name: "add"
    description: "Add two values."
    impls:
      - args:
         - name: x
           value: i8
         - name: y
           value: i8
        options:
          overflow:
            values: [ SILENT, SATURATE, ERROR ]
        return: i8
"#;

let simple_extension = serde_yaml::from_str::<SimpleExtensions>(simple_extension_yaml)?;

assert_eq!(simple_extension.scalar_functions.len(), 1);
assert_eq!(simple_extension.scalar_functions[0].name, "add");

Dependencies

~5–9.5MB
~184K SLoC