Thalweg · API reference ← Main docs

Module remote

Module remote 

Source
Expand description

Remote UDF execution over Arrow Flight.

Registration is driven by a TOML manifest describing one or more services, each exposing one or more functions:

  • manifest: parse and validate the manifest (transports, limits, types).
  • transport: mTLS / sidecar connections and the bounded DoExchange call.
  • udf_impl: the udf_impl::RemoteUdf async scalar UDF.
  • validate: response containment checks and the circuit breaker.
  • observability: per-function metrics (exported) and audit logging.
  • bridge: the arrow-58 ↔ arrow-59 RecordBatch bridge.

Modules§

bridge
Arrow ↔ DataFusion RecordBatch bridge for the remote UDF layer.
manifest
Remote UDF manifest parsing and validation.
observability
Observability for remote UDFs: per-service/function metrics and audit logging.
transport
Transport layer for remote UDFs via Arrow Flight.
udf_impl
Remote UDF implementation via Arrow Flight.
validate
Response validation and the per-service circuit breaker.

Enums§

RemoteError
A failure anywhere on the remote call path.

Functions§

register_remote_udfs
Register remote UDFs from a manifest file, recording metrics into metrics.