Module routing 

Row-to-vnode routing shared by checkpointed cluster shuffle paths.

Structs

CheckpointRoutePlan

Complete, conserving routing plan staged before any remote send.

LocalRoute

A local vnode slice in deterministic vnode order.

RemoteRoute

One bounded owner-coalesced remote batch.

Enums

ShuffleRoutingError

A routing failure. No plan is returned, so callers cannot partially send or silently drop rows.

Constants

ROUTE_MAX_BATCH_BYTES

Hard decoded size admitted for one logical shuffle batch.

ROUTE_MAX_BATCH_ROWS

Row-count bound prevents tiny or zero-width rows from producing unbounded logical frames.

ROUTE_TARGET_BATCH_BYTES

Target decoded size for one routed batch. This is intentionally below the hard receiver bound so schema/allocator variance does not turn ordinary skew into a transport failure.

Functions

route_checkpointed_batch

Build a complete local/remote plan from one caller-pinned assignment.

row_vnodes

Hash each row with the engine’s canonical Arrow-row and xxh3 encoding.