Crate arrow_udf_flight

Remote UDF based on Arrow Flight

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

Server

Currently the following languages are supported:

• Python
• Java

Please click the link to see the specific usage.

Client

Add the following lines to your Cargo.toml:

[dependencies]
arrow-udf-flight = "0.4"

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.

Re-exports

pub use arrow_flight;

Structs

Client

Client for a remote Arrow UDF service.

Function

Function signature.

Enums

Error

The error type for UDF operations.

Type Aliases

Result

A specialized Result type for UDF operations.