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

#355 in Network programming

Download history 385/week @ 2024-07-29 373/week @ 2024-08-05 581/week @ 2024-08-12 613/week @ 2024-08-19 427/week @ 2024-08-26 540/week @ 2024-09-02 418/week @ 2024-09-09 596/week @ 2024-09-16 797/week @ 2024-09-23 214/week @ 2024-09-30 718/week @ 2024-10-07 855/week @ 2024-10-14 573/week @ 2024-10-21 521/week @ 2024-10-28 497/week @ 2024-11-04 381/week @ 2024-11-11

1,987 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

~15–22MB
~306K SLoC