Module state_match

This module contains the logic for matching the internal state tables of two streaming jobs, used for replacing a streaming job (typically ALTER MV) while preserving the existing state.

Macros

bail_fragment 🔒

Constructs a Error::Fragment variant and bails out.

bail_graph 🔒

Constructs a Error::Graph variant and bails out.

bail_operator 🔒

Constructs a Error::Operator variant and bails out.

fragment 🔒

Constructs a Error::Fragment variant.

graph 🔒

Constructs a Error::Graph variant.

operator 🔒

Constructs a Error::Operator variant.

Structs

Fragment 🔒

Node for a fragment in the Graph.

Graph

A streaming job graph that’s used for state table matching.

Match 🔒

The match result of a fragment in the source graph to a fragment in the target graph.

Matches 🔒

The successful matching result of two Graphs.

StreamNodeDesc 🔒

Helper type for describing a [StreamNode] in error messages.

Enums

Error 🔒

Error type for failed state table matching.

Functions

match_graph 🔒

Matches two Graphs, and returns the match result from each fragment in g1 to g2.

match_graph_internal_tables 🔒

Matches two Graphs, and returns the internal table mapping from g1 to g2.

Type Aliases

Id 🔒

Fragment id.

Result 🔒