Function serialize

datafusion/substrait/src/serializer.rs:36–51

Plans a sql and serializes the generated logical plan to bytes. The bytes are then written into a file at `path`. Returns an error if the file already exists.

(
    sql: &str,
    ctx: &SessionContext,
    path: impl AsRef<Path>,
)

///
/// Returns an error if the file already exists.
pub async fn serialize(
    sql: &str,
    ctx: &SessionContext,
    path: impl AsRef<Path>,
) -> Result<()> {
    let protobuf_out = serialize_bytes(sql, ctx).await?;

    let mut file = OpenOptions::new()
        .write(true)
        .create_new(true)
        .open(path)
        .await?;
    file.write_all(&protobuf_out).await?;
    file.flush().await?;
    Ok(())
}

/// Plans a sql and serializes the generated logical plan to bytes.
pub async fn serialize_bytes(sql: &str, ctx: &SessionContext) -> Result<Vec<u8>> {