arrow-udf-runtime 0.9.0

Runtime for Arrow UDFs.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

# Remote UDF based on Arrow Flight

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

[Arrow Flight RPC]: https://arrow.apache.org/docs/format/Flight.html

## Server

Currently the following languages are supported:

- [Python](https://github.com/risingwavelabs/arrow-udf/tree/main/arrow-udf-remote/python)
- [Java](https://github.com/risingwavelabs/arrow-udf/tree/main/arrow-udf-remote/java)

Please click the link to see the specific usage.

## Client

Add the following lines to your `Cargo.toml`:

```toml
[dependencies]
arrow-udf-runtime = "0.7"
```

```rust,ignore
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.