pub struct IngestOptions {
pub table: String,
pub mode: String,
pub schema_override: Option<Map<String, Value>>,
pub merge_key: Option<Vec<String>>,
}Expand description
Controls how data is loaded into a target table.
Fields§
§table: String§mode: String"replace" drops the existing table first; "append" adds rows to
it; "merge" upserts rows by Self::merge_key.
schema_override: Option<Map<String, Value>>When set, bypasses schema inference and uses these exact column types.
merge_key: Option<Vec<String>>When mode == "merge", the column(s) to match on for upsert. Required
in merge mode; rejected in any other mode (the per-call site validates
up-front so the lower ingest paths can stay format-agnostic).
Trait Implementations§
Auto Trait Implementations§
impl Freeze for IngestOptions
impl RefUnwindSafe for IngestOptions
impl Send for IngestOptions
impl Sync for IngestOptions
impl Unpin for IngestOptions
impl UnsafeUnpin for IngestOptions
impl UnwindSafe for IngestOptions
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
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> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request