Struct Client 

pub struct Client { /* private fields */ }

Client for a remote Arrow UDF service.

Implementations

impl Client

pub async fn connect(addr: impl Into<String>) -> Result<Self>

Connect to a UDF service.

pub async fn new(client: FlightServiceClient<Channel>) -> Result<Self>

Create a new client.

pub fn protocol_version(&self) -> u8

Get protocol version.

pub async fn get(&self, name: &str) -> Result<Function>

Get function schema.

pub async fn list(&self) -> Result<Vec<Function>>

List all available functions.

pub async fn call(&self, name: &str, input: &RecordBatch) -> Result<RecordBatch>

Call a function.

pub async fn call_table_function( &self, name: &str, input: &RecordBatch, ) -> Result<impl Stream<Item = Result<RecordBatch>> + Send + 'static>

Call a table function.

Trait Implementations

impl Debug for Client

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.