Struct dataflow::render::ComputeState

pub struct ComputeState {
    pub traces: TraceManager,
    pub dataflow_tokens: HashMap<GlobalId, Box<dyn Any>>,
    pub tail_response_buffer: Rc<RefCell<Vec<(GlobalId, TailResponse)>>>,
    pub sink_write_frontiers: HashMap<GlobalId, Rc<RefCell<Antichain<Timestamp>>>>,
}

Worker-local state that is maintained across dataflows.

This state is restricted to the COMPUTE state, the deterministic, idempotent work done between data ingress and egress.

Fields

traces: TraceManager

The traces available for sharing across dataflows.

dataflow_tokens: HashMap<GlobalId, Box<dyn Any>>

Tokens that should be dropped when a dataflow is dropped to clean up associated state.

tail_response_buffer: Rc<RefCell<Vec<(GlobalId, TailResponse)>>>

Shared buffer with TAIL operator instances by which they can respond.

The entries are pairs of sink identifier (to identify the tail instance) and the response itself.

sink_write_frontiers: HashMap<GlobalId, Rc<RefCell<Antichain<Timestamp>>>>

Frontier of sink writes (all subsequent writes will be at times at or equal to this frontier)