Struct SinkCtx 

#[non_exhaustive]
pub struct SinkCtx {
    pub task: u32,
    pub sink: u32,
    pub emitted: Arc<Atomic<u64>>,
    pub exactly_once: bool,
    pub restore: Option<u64>,
    pub acker: Arc<dyn Fn(u64) + Send + Sync>,
    pub pipeline: String,
    pub build_id: String,
}

What a sink is built with: its task id and its index sink within the output (the files it names); the emitted counter; whether output is exactly-once (visibility gated on the epoch commit); the checkpoint epoch a restored run continues from (None: a fresh run starts the output over); the barrier Acker; and the run’s identity (a transactional id is pipeline + the task). Built by the engine only (#[non_exhaustive]: new fields arrive as setters).

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

task: u32

sink: u32

emitted: Arc<Atomic<u64>>

exactly_once: bool

restore: Option<u64>

acker: Arc<dyn Fn(u64) + Send + Sync>

pipeline: String

build_id: String

Implementations

impl SinkCtx

pub fn new( task: u32, sink: u32, emitted: Arc<Atomic<u64>>, acker: Arc<dyn Fn(u64) + Send + Sync>, ) -> SinkCtx

pub fn exactly_once(self, exactly_once: bool) -> SinkCtx

pub fn restore(self, epoch: Option<u64>) -> SinkCtx

pub fn run(self, pipeline: &str, build_id: &str) -> SinkCtx

Trait Implementations

impl Clone for SinkCtx

fn clone(&self) -> SinkCtx

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.