Module remote

arrow_udf_runtime

Module remote 

Source
Expand description

§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:

Please click the link to see the specific usage.

§Client

Add the following lines to your Cargo.toml:

[dependencies]
arrow-udf-runtime = "0.7"
ⓘ
use arrow_udf_runtime::remote::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.