Skip to main content

SqlTransform

faucet_transform_sql

Struct SqlTransform

pub struct SqlTransform { /* private fields */ }

Expand description

A compiled SQL transform. One DuckDB connection, reused across the row’s pages.

Implementations§

impl SqlTransform

pub fn compile(cfg: &SqlTransformConfig) -> Result<Self, FaucetError>

Build the connection, load reference relations, and validate the query.

pub fn into_page_stage(self) -> TransformStage

Consume into a page-level Value transform stage.

pub fn into_columnar_stage(self) -> (TransformStage, PageFnBatchBox)

Consume into a Value page stage plus an Arrow RecordBatch → Record Batch form that shares the same DuckDB connection (#375). The CLI passes the batch fn to TransformingSource::new_with_batches, so a parquet → sql → parquet chain runs Arrow end-to-end (no Value materialization) while any other chain keeps using the Value page stage.

Trait Implementations§

impl Debug for SqlTransform

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

impl Freeze for SqlTransform

impl RefUnwindSafe for SqlTransform

impl Send for SqlTransform

impl Sync for SqlTransform

impl Unpin for SqlTransform

impl UnsafeUnpin for SqlTransform

impl UnwindSafe for SqlTransform

Blanket Implementations§

impl<T> Allocation for T
where T: RefUnwindSafe + Send + Sync,

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T, U> Into<U> for T
where U: From<T>,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more

impl<T, U> TryFrom<U> for T
where U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more