4 releases (breaking)

0.4.0 Oct 10, 2024
0.3.0 Sep 19, 2024
0.2.0 Jul 3, 2024
0.1.0 May 7, 2024

#411 in Network programming

Download history 833/week @ 2024-09-19 486/week @ 2024-09-26 229/week @ 2024-10-03 981/week @ 2024-10-10 728/week @ 2024-10-17 586/week @ 2024-10-24 457/week @ 2024-10-31 418/week @ 2024-11-07 623/week @ 2024-11-14 666/week @ 2024-11-21 456/week @ 2024-11-28 441/week @ 2024-12-05 397/week @ 2024-12-12 416/week @ 2024-12-19 307/week @ 2024-12-26 505/week @ 2025-01-02

1,724 downloads per month

Apache-2.0

125KB
2.5K SLoC

Java 1.5K SLoC // 0.2% comments Python 792 SLoC // 0.2% comments Rust 158 SLoC // 0.2% comments

Remote UDF based on Arrow Flight

Crate Docs

Run user-defined functions in a separate process and call them via Arrow Flight RPC.

Server

Currently the following languages are supported:

Please click the link to see the specific usage.

Client

Add the following lines to your Cargo.toml:

[dependencies]
arrow-udf-flight = "0.2"
use arrow_udf_flight::Client;

// Connect to the UDF server
let client = Client::new("localhost:8815").await.unwrap();

// Call functions
let input: RecordBatch = ...;
let output: RecordBatch = client.call("gcd", &input).await.unwrap();

Communication Protocol

The communication protocol between client and server is based on Arrow Flight RPC.

Details to be added.

Dependencies

~14–22MB
~306K SLoC