Crate mz_compute

Materialize’s compute layer.

Modules

arrangement 🔒

Types related to the arrangement and management of collections.

communication

Code to spin up communication mesh for a compute replica. Most of this logic was taken from Timely’s communication::networking module, with the crucial difference that we actually verify that we can receive data on a connection before considering it established, and retry otherwise. This allows us to cope with the phenomenon of spuriously accepted connections that has been observed in Kubernetes with linkerd.

compute_state

Worker-local state for compute timely instances.

logging 🔒

Logging dataflows for events generated by various subsystems.

render 🔒

Renders a plan into a timely/differential dataflow computation.

server

An interactive dataflow server.

sink 🔒

typedefs 🔒

Convience typedefs for differential types.

Structs

TraceManager

A TraceManager stores maps from global identifiers to the primary arranged representation of that collection.

TraceMetrics

Base metrics for arrangements.