pub struct CodegenOptions {
pub source: SourceKind,
pub sink: SinkKind,
pub mode: PlanMode,
pub batch_rows: usize,
pub concurrency: usize,
pub checkpoint: String,
pub declared_tier: Tier,
}Expand description
Knobs for GraphPlan::from_mapping. Defaults match the rel2graph spec
(1000-row UNWIND batches, single coalesced writer, Iceberg→FalkorDB batch).
Fields§
§source: SourceKindThe source plane the schema was read from.
sink: SinkKindThe graph sink to load.
mode: PlanModeBatch or streaming (streaming needs an Iceberg source).
batch_rows: usizeRows per UNWIND … MERGE batch (the idempotent write unit).
concurrency: usizeWriter concurrency — the coalesce(N) partition count the sink client
runs inside.
checkpoint: StringThe single checkpoint / storage location (one per query).
declared_tier: TierThe tier the declared mapping elements are attributed to. A reviewed
MappingSpec is T3 (its knut.* properties); a spec derived straight
from an Iceberg schema is T2. The live-catalog T1 resolution is a
worklist item (see the design doc).
Trait Implementations§
Source§impl Clone for CodegenOptions
impl Clone for CodegenOptions
Source§impl Debug for CodegenOptions
impl Debug for CodegenOptions
Auto Trait Implementations§
impl Freeze for CodegenOptions
impl RefUnwindSafe for CodegenOptions
impl Send for CodegenOptions
impl Sync for CodegenOptions
impl Unpin for CodegenOptions
impl UnsafeUnpin for CodegenOptions
impl UnwindSafe for CodegenOptions
Blanket Implementations§
impl<T> Allocation for T
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more