pub struct ExportRequest<'a> {
pub query: &'a str,
pub incremental: Option<&'a IncrementalCursorPlan>,
pub cursor: Option<&'a CursorState>,
pub tuning: &'a SourceTuning,
pub column_overrides: &'a ColumnOverrides,
}Expand description
Read-only inputs for a single export call.
Packs the parameters that used to live as 5 positional args on
Source::export into a named struct. sink is not part of this struct
— it is &mut and conceptually the output channel, separate from the
read-only request configuration.
Fields§
§query: &'a strAlready-materialized SQL (after resolve_query). The driver still wraps
it with the dialect-specific incremental predicate via
[crate::source::query::build_incremental_query] when incremental is set.
incremental: Option<&'a IncrementalCursorPlan>§cursor: Option<&'a CursorState>§tuning: &'a SourceTuning§column_overrides: &'a ColumnOverridesPer-column type declarations from rivet.yaml (exports[].columns:).
Drivers apply them during schema building so e.g. a NUMERIC column
without declared precision can still be exported as Decimal128(18,2)
when the user has stated the type explicitly.
Auto Trait Implementations§
impl<'a> Freeze for ExportRequest<'a>
impl<'a> RefUnwindSafe for ExportRequest<'a>
impl<'a> Send for ExportRequest<'a>
impl<'a> Sync for ExportRequest<'a>
impl<'a> Unpin for ExportRequest<'a>
impl<'a> UnsafeUnpin for ExportRequest<'a>
impl<'a> UnwindSafe for ExportRequest<'a>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more