Struct MssqlOutputWriteJob 

pub struct MssqlOutputWriteJob { /* private fields */ }

One deferred SQL Server output write job.

The job owns an already resolved SQL Server target plus a lazy batch stream factory. The workflow awaits the factory only after the output becomes the next attempted output. Skipped jobs keep their stream factories uncalled, so skipped outputs do not start source reads, DataFusion execution, stream setup, SQL connections, lifecycle preparation, writer initialization, or batch polling through this API.

Implementations

impl MssqlOutputWriteJob

pub fn new<F, Fut, S>( output_schema: SchemaRef, resolved_target: ResolvedMssqlTarget, schema_options: MssqlSchemaPlanOptions, batches: F, write_options: MssqlWriteOptions, validation_options: ValidationOptions, ) -> Self

where F: FnOnce() -> Fut + Send + 'static, Fut: Future<Output = Result<S, DeltaFunnelError>> + Send + 'static, S: Stream<Item = Result<RecordBatch, DeltaFunnelError>> + Send + 'static,

Creates a deferred SQL Server output write job.

pub fn with_phase_timings(self, phase_timings: Vec<PhaseTimingReport>) -> Self

Adds phase timings that completed before this deferred write job runs.

pub fn with_default_write_options<F, Fut, S>( output_schema: SchemaRef, resolved_target: ResolvedMssqlTarget, schema_options: MssqlSchemaPlanOptions, batches: F, ) -> Self

where F: FnOnce() -> Fut + Send + 'static, Fut: Future<Output = Result<S, DeltaFunnelError>> + Send + 'static, S: Stream<Item = Result<RecordBatch, DeltaFunnelError>> + Send + 'static,

Creates a deferred SQL Server output write job using default write options.

pub fn output_name(&self) -> &str

Returns the selected output name.

pub fn target_summary(&self) -> MssqlTargetSummary

Returns a redacted target summary for reports.

pub fn phase_timings(&self) -> &[PhaseTimingReport]

Returns phase timings that completed before this deferred write job runs.