Struct UdfServiceConnection 

pub struct UdfServiceConnection {
    pub service_id: String,
    pub transport: Transport,
    /* private fields */
}

A pooled connection to a remote UDF service, shared across its functions.

Fields

service_id: String

transport: Transport

Implementations

impl UdfServiceConnection

pub async fn new( service_id: String, transport: Transport, connect_timeout: Duration, ) -> Result<Self, TransportError>

Connect to a remote UDF service (fail-fast at startup).

Errors

Returns a TransportError if the connection or handshake fails.

pub async fn do_exchange( &self, function_name: &str, input: RecordBatch, max_response_bytes: usize, ) -> Result<Vec<RecordBatch>, RemoteError>

Call DoExchange for function_name, sending input and collecting the response batches under a streaming byte ceiling.

The byte ceiling is checked incrementally: as soon as the cumulative response size exceeds max_response_bytes the call fails with ValidationError::ResponseTooLarge, before the remaining batches are read — an oversized worker cannot force the whole response into memory.

Input/output batches are arrow-59 (arrow-flight’s arrow); callers bridge to/from DataFusion’s arrow-58 batches.

Errors

Returns a RemoteError on transport failure or when the response exceeds the byte ceiling.

Trait Implementations

impl Debug for UdfServiceConnection

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

Formats the value using the given formatter.