基于 Arrow Flight 的远程 UDF

在单独的进程中运行用户定义的函数，并通过 Arrow Flight RPC 调用它们。

服务器

当前支持以下语言

• Python
• Java

请点击链接查看具体用法。

客户端

将以下行添加到您的 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();

通信协议

客户端和服务器之间的通信协议基于 Arrow Flight RPC。

详细信息待补充。