Module write 

Implementation of the write operator.

Structs

BatchUpdates 🔒

The payload of a coalesced WriteCommand::Batch.

State 🔒

State maintained by the write operator on the Timely thread.

WriteResponse 🔒

A response from the Tokio write task back to the Timely operator.

Enums

WriteCommand 🔒

Commands sent from the Timely operator to the Tokio write task.

Constants

READ_BACK_CHUNK 🔒

How many updates the batch read-back hands over per chunk.

READ_BACK_CHUNKS_IN_FLIGHT 🔒

How many chunks may sit between the blocking read-back and the async task feeding the batch builder. Together with READ_BACK_CHUNK this bounds the handoff to a few thousand buffered updates.

Functions

apply_batch 🔒

Apply a coalesced batch of updates to the correction buffers, on a blocking thread.

apply_command 🔒

Apply a single command to the task state, returning the correction buffers.

render

Render the write operator.

Type Aliases

Corrections 🔒

The correction buffers owned by the Tokio write task.